| blob | 1b6e1e9b0b0f60a01cf5a4cb9d30ca8350883b44 |
44 import DFMapBuilder
45 import GroovyFileFilter
50 def name
52 def ids = [:]
53 def names
55 def pendingCommands = [:]
58 def sauerSocket
61 def swing
62 def gui
63 def fields = [:]
65 def pastryCmd
67 def peerId
68 def sauerDir
69 def plexusDir
70 def cacheDir
71 def mapDir
73 def sandbox
74 def peer
75 def mapname
76 def costume
77 def mapTopic
78 def mapProps = [:]
79 def newMapHookBlock
80 def globalProps = [:]
81 def mapIsPrivate
82 /** cloudProperties is the shared properties object for PLEXUS
83 * its keys are path-strings, representing information organized in
84 * a tree
85 */
86 def cloudProperties
87 def plexusTopic
89 def playerCount = [:]
90 def triggerLambdas = [:]
91 def portals = [:]
92 def receivedCloudPropertiesHooks = [
94 ]
96 def neighborField
97 def playerListeners = [:]
98 def maps
99 def mapCombo
100 def mapPlayers
101 def mapPlayersCombo
102 def launchSauerButton
103 def downloadPanel
104 def downloadProgressBar
105 def uploadCountField
106 def downloadCountField
107 def cloudLight
108 def loadTypeField
109 def followingPlayer
110 def cotumeUploadField
111 def tumes
112 def tumesCombo
113 def fileQ = []
114 def executorThread
115 def pendingDownloads = [] as Set
119 def cloudFields = [:]
120 def mappingFields = [:]
121 def pastryFields = [:]
122 def cachedPlayerLocations = [:]
123 def cachedLocationDoc
124 def myCachedLocation
128 def static sauerExec
136 }
139 println "Usage: Plexus port name pastryArgs"
141 }
143 }
146 def f = dir as File
152 }
153 }
155 }
162 }
165 println "TST: $a, $b"
166 }
170 }
172 }
173 /**
174 * Exec a block of code asynchronously, hence exec() does not return a value from the block.
175 */
182 }
183 })
184 }
186 exec {
188 }
197 }
201 }
203 cloudProperties = new CloudProperties(this, new File(plexusDir, "cache/$name/cloud.properties"))
212 }
227 println "Costume changed. Loading new costume for $pl"
229 }
230 }
231 }
232 }
238 }
241 }
242 }
250 sauer('private', "tc_msgbox [You received the key to a private world, $map.name: $map.id] [from $player.name ($player.id)]")
251 }
254 }
255 }
257 println "CLOUD PROPERTY REMOVE HOOK"
259 }
266 def data = []
270 }
272 }
273 }
274 //PlasticLookAndFeel.setPlasticTheme(new DesertBlue());
276 // UIManager.setLookAndFeel(new Plastic3DLookAndFeel());
280 //start(args[0])
286 println "RECEIVED MAP NOTIFICATION, DOWNLODING..."
288 }
292 println "RECEIVED MAP NOTIFICATION, DOWNLODING..."
294 }
295 }
301 }
306 exec {
310 println "Going to remove '${ids[id]}' from names"
312 pastryCmd = cmd
315 }
317 }
318 }
321 }
323 {
326 }
327 //sauer('peers', "peers ${peer.getNeighborCount()}")
328 //dumpCommands()
329 },
335 }
338 // println "Node ID: $peerId}"
339 println "SAVED NODE ID: $LaunchPlexus.props.nodeId"
342 println "SAVING NEW NODE ID: $LaunchPlexus.props.nodeId"
344 }
348 println "execing init..."
349 exec {
352 }
354 println "initBoot"
357 println "initJoin"
359 }
363 }
368 }
369 }
370 }
372 def buf = ("" << "<html><body>${prologue ?: ''}<table><tr colspan=\"$cols\" style=\"background-color: rgb(192,192,192)\"><td><div>$header</div></td></tr>\n")
381 count++
382 }
392 }
393 }
394 }
399 exec {
400 println "RECEVED ${type.toUpperCase()}, CHECKPOINTING CLOUD PROPS"
405 }
406 }, receiveException: {ex -> err("Could not fetch data for $type: $id -> ${new File(plexusDir, "cache/$name/$location")}", ex)})
407 }
412 }
413 exec {
416 }
421 }
428 }
431 }
432 println "destroying node"
434 }
437 println "cleaning up UPNP mappings"
439 }
440 println "exiting"
442 }
443 }
444 }
447 gui = swing.frame(title: "PLEXUS [${LaunchPlexus.props.name}]", size: [500, 500], windowClosing: {die()}, pack: true, show: true) {
451 textPainter(text: label, font: new FontUIResource("SansSerif", Font.BOLD, 12), fillPaint: new Color(0xFF, 0x99, 0x00))
452 glossPainter(paint:new Color(1.0f,1.0f,1.0f,0.2f), position: pos ?: GlossPainter.GlossPosition.TOP)
453 }
454 }
457 fields[key] = textField(actionPerformed: {sauerEnt(key)}, focusLost: {sauerEnt(key)}, constraints: 'wrap, growx')
458 }
459 titledPanel(title: ' ', titlePainter: makeTitlePainter("PLEXUS [${LaunchPlexus.props.name}]: Killer App of the Future - Here Today!"), border: new DropShadowBorder(Color.BLACK, 15)) {
468 }
471 }
474 }
481 launchSauerButton = button(text: "Launch Sauerbraten", actionPerformed: {launchSauer()}, enabled: false)
485 }
488 exec {
491 }
492 }
496 exec {
504 }
505 }
506 }
510 exec {
512 followingPlayer = mapPlayersCombo.selectedIndex ? mapPlayers[mapPlayersCombo.selectedIndex - 1] : null
513 println "NOW FOLLOWING: ${followingPlayer?.name}"
519 }
520 }
521 }
522 }
525 exec {
528 }
529 }
530 })
534 })
536 exec {
541 }
542 }
543 })
544 }
545 }
546 }
547 }
569 }
570 }
571 }
578 }
579 }
583 }
586 }
587 }
589 button(text: 'Update', actionPerformed: {exec {updateCachedLocationDoc()}}, constraints: 'wrap')
592 }
593 }
598 }
599 }
600 }
601 label(minimumSize: [24,24], text: ' ', foregroundPainter: makeTitlePainter('Copyright (C) 2008, TEAM CTHULHU', GlossPainter.GlossPosition.BOTTOM), constraints: 'growx, spanx, height 24, wrap')
602 }
603 }
605 downloadPanel = panel(layout: new MigLayout('ins 0 2 0 2,fillx'), constraints: new JXStatusBar.Constraint(JXStatusBar.Constraint.ResizeBehavior.FILL)) {
614 }
615 }
616 }
617 }
622 buf << "<tr><td>$it.key</td><td>${it.value[0]}</td><td><div>${it.value[1].join(' ')}</div></td></tr>"
623 }
626 }
632 }
635 ch.setFileFilter(new GroovyFileFilter(filterName) {it.isDirectory() || it.name ==~ filterRegexp})
636 def result = ch.showOpenDialog(null) == JFileChooser.APPROVE_OPTION ? ch.getSelectedFile() : null
639 }
640 return result
641 }
646 }
649 exec {
650 def env = []
658 }
659 }
664 commandLine += " \"-xalias sauerPort $LaunchPlexus.props.sauer_port;alias sauerHost 127.0.0.1\""
666 def args = []
674 }
678 }
679 }
680 }
684 println who
690 println mapPath
692 }
693 }
694 return result
695 }
700 ch.setFileFilter(new GroovyFileFilter("DF ASCII MAPS (*.txt)") {it.isDirectory() || it.name.toLowerCase().endsWith(".txt")})
708 }
709 }
710 }
711 }
713 // generate a random dungeon
717 exec {
718 sauer('newmap', 'if (= 1 $editing) [ edittoggle ]; tc_allowedit 1; thirdperson 0; newmap; musicvol 0')
721 }
735 //println "x: $x y: $y"
737 exec {
742 }
745 }
748 }
751 }
753 }
754 }
755 }
756 }
758 exec {
763 }
772 exec {
776 }
780 }
782 }
783 }
784 }
785 }
787 exec {
788 sauer("spawn", "selcube 32 32 416 1 1 1 32 5; ent.yaw p0 135; newent playerstart; tc_respawn p0")
791 }
792 };
793 }
794 //Plexus.bindLevelTrigger(35, 'remotesend levelTrigger 35 $more $data') {println "duh"} remotesend levelTrigger 35
801 }
804 println "sauer trigger: $trigger"
806 }
808 println msg
809 println "usage: ${getClass().name} port name"
810 println "System property sauerdir must hold your Sauerbraten distribution directory"
811 }
814 // don't enable socket to sauer til after we've joined the ring
817 //sauerSocket.setSoTimeout(10);
821 println "READY"
831 exec {
836 }
837 }
838 }
846 }
848 println "Disconnect"
849 };
851 }
852 }
853 }
857 }
860 }
866 // println out
867 if (P2PMudPeer?.sauerLogFile) { P2PMudPeer.sauerLogFile << new Date().toString() << ' ' << out; }
869 output << out
875 }
876 }
877 pendingCommands = [:]
878 }
879 }
883 exec {
886 }
887 }
888 }
894 exec {
897 }
898 }
899 }
905 println "pi $playerInfo"
906 return playerInfo
907 }
909 exec {
917 'echo INIT'
923 }
924 }
928 }
932 }
937 }
939 }
943 }
945 "$name-${TIME_STAMP.format(new Date())}"
946 }
950 println "Loading map: ${id}"
953 }
960 println "Retrieved map from PAST: $dir, executing: map [$mapPath/map]"
965 }
966 }
972 }
973 })
974 }
977 }
983 }
987 }
988 }
993 }
998 uploads++
1001 queueIo(cont, {uploads--; updateDownloads(); clearUploadProgress()}) {chain -> peer.wimpyStoreFile(cacheDir, file, {showUploadProgress(chunk++, total)}, chain, mutable, cacheOverride)}
1002 }
1004 uploads++
1007 queueIo(cont, {uploads--; updateDownloads(); clearUploadProgress()}) {chain -> P2PMudFile.storeDir(cacheDir, dir, {chunk, total -> showUploadProgress(chunk, total)}, chain)}
1008 }
1012 downloads++
1015 queueIo(cont, {downloads--; updateDownloads(); clearDownloadProgress()}) {chain -> peer.wimpyGetFile(id, cacheDir, {total -> showDownloadProgress(chunk++, total)}, chain)}
1016 }
1018 downloads++
1021 queueIo(cont, {downloads--; updateDownloads(); clearDownloadProgress()}) {chain -> P2PMudFile.fetchDir(id, cacheDir, dir, {chunk, total -> showDownloadProgress(chunk, total)}, chain, mutable)}
1022 }
1026 println "EXECUTING"
1029 println "QUEUING"
1031 }
1032 }
1035 exec {
1036 println "DONE"
1040 }
1042 exec {
1043 println "ERROR"
1047 }
1048 })
1049 }
1053 }
1054 }
1057 def files = []
1059 println "STORING CACHE"
1064 }
1065 }
1067 println "FINISHED PUSHING CACHE"
1068 // sauer('msg', 'tc_msgbox Ready [Finished pushing cache in PAST]')
1069 // dumpCommands()
1071 println "FAILED TO PUSH CACHE"
1074 println "STORING FILE: $file"
1076 }
1078 println "NO CACHE TO STORE"
1079 }
1080 }
1083 }
1088 println "BROADCAST PROPERTY: $key=$value"
1089 }
1092 println "REMOVING CLOUD PROPERTY"
1096 }
1097 println "BROADCAST REMOVE PROPERTY: $key"
1098 }
1101 println "REMOVING CLOUD PROPERTY"
1103 }
1108 }
1111 def map
1116 }
1120 }
1125 /*
1126 return [
1127 id: id,
1128 dir: entry[0],
1129 name: entry[1..-1].join(' '),
1130 privateMap: privateMap
1131 ]
1132 */
1133 }
1134 return map
1135 }
1138 def pl
1144 /*
1145 pl = [
1146 id: id,
1147 map: entry[0] == 'none' ? null : entry[0],
1148 costume: entry[1] == 'none' ? null : entry[1],
1149 name: entry[2..-1].join(' ')
1150 ]
1151 */
1152 }
1153 return pl
1154 }
1157 def costume
1160 }
1164 return costume
1165 /*
1166 return [
1167 id: id,
1168 thumb: entry[0] == 'none' ? null : entry[0],
1169 type: entry[1],
1170 name: entry[2..-1].join(' ')
1171 ]
1172 */
1173 }
1174 return costume
1175 }
1177 println "newmap: $name"
1185 }
1191 }
1192 mapname = name
1194 def groovyScript = name ==~ '[^/]*' ? new File(sauerDir, "packages/base/${name}.groovy") : new File(sauerDir, "packages/${name}.groovy")
1203 }
1204 }
1206 mapProps = [:]
1213 }
1214 }
1215 }
1220 println "UPDATING PLAYER INFO"
1221 // after we get the players list, send ourselves out
1223 //TODO put tume in here and persist in props
1224 transmitSetCloudProperty("player/$node", new JSONWriter().write([map: id, costume: costume, name: name, guild: LaunchPlexus.props.guild]))
1225 }
1226 }
1233 println "Going to remove player $who.name from sauer: $sauerId"
1235 }
1242 }
1246 println "WARNING: can't find id for player: $peerId"
1247 }
1248 }
1257 ++id_index
1258 sauer('prep', "echo [Welcome player $name to this world.]; createplayer $sauerid $name; playerinfo $sauerid \"$guild\"")
1262 }
1263 return sauerid
1264 }
1267 def data = []
1271 }
1273 data = []
1276 }
1278 }
1281 def data = []
1288 }
1290 }
1291 showData(pastryFields.topics, "Topics", 2, data, "", "Neighbors: ${peer.getNeighborCount()}<br>Route State...<br><pre>${peer.routeState()}</pre><br>")
1292 }
1310 }
1311 }
1312 }
1315 mapPlayers = newMapPlayers
1323 }
1325 }
1326 }
1329 }
1330 }
1332 println "DUMPING PLAYERS TO SAUER"
1333 def PlayerGui = 'alias showpcostume [ guibar; guiimage (concatword "packages/plexus/models/thumbs/" (get $pcostumenames $guirollovername)) $guirolloveraction 4 1 "packages/plexus/dist/tc_logo.jpg"];'
1340 } )
1354 PlayerGui += "guibutton [$who.name ($map)] [alias tc_whisper $who.id; alias selected_player [$who.name]; alias mapIsPrivate $mapIsPrivate; showgui Player]\n"
1355 ++cnt
1364 }
1365 }
1369 ++mapCnt
1370 }
1371 } )
1373 //PlayerGui += "guibar\n guibutton Close [cleargui]\n"
1379 println "MAPCNT: $mapCnt"
1381 }
1382 // bump counts to include ourself
1383 ++cnt
1384 ++mapCnt
1385 PlayerGui += "]; peers $cnt; tc_mapcount $mapCnt" // ;tc_loadmsg ${allPlayers ? myMap.name : 'none'}"
1388 }
1394 }
1397 def ents = []
1398 def privates = []
1400 playerCount = [:]
1403 }
1406 }
1412 }
1413 }
1415 def newMaps = []
1421 }
1424 def mapsGui = 'alias showmapthumb [ guibar; guiimage (concatword "packages/plexus/cache/' + name + '/maps/" (get $mapthumbs $guirollovername) "/map.jpg") $guirolloveraction 4 1 "packages/plexus/dist/tc_logo.jpg"];'
1428 }
1443 }
1444 }
1445 }
1449 maps = newMaps
1457 }
1459 }
1460 }
1466 }
1472 }
1473 }
1476 mapsGui += "guibutton [${world[0]} (${world[2]})] [remotesend createPortal ${world[0]} ${world[1]}]\n"
1477 }
1481 }
1484 println "loading costume: $who.costume"
1496 })
1497 }
1498 }
1499 }
1501 println "Clothing $who.id with costume: $costumeDir"
1502 println "SENDING: playerinfo ${ids[who.id]} [${who.guild ?: ''}] $costumeDir"
1505 }
1507 println "PUSHING COSTUME: $name"
1509 }
1515 println "STORING COSTUME"
1524 }
1526 println "STORED COSTUME, adding"
1527 transmitSetCloudProperty("costume/$fileId", new JSONWriter().write([thumb: thumb, type: thumb ? type : null, name: name]))
1531 }
1535 })
1536 }
1537 }
1542 return
1543 }
1547 def tumes = []
1548 def needed = []
1549 def present = [] as Set
1559 }
1560 }
1562 println "Tumes: $tumes, Needed: $needed"
1572 }
1577 //cut out if we have been superceded
1586 i++
1588 },
1593 }
1596 }
1597 }
1599 def trips = []
1611 }
1613 }
1614 }
1617 }
1618 //varval = [do [result $@arg1]]
1619 //x3 = hello; v = 3; echo (varval (concatword x $v))
1620 /**
1621 * name, thumb path, costume id
1622 */
1626 println "COSTUME SELS: $triples"
1628 guitext += 'alias showcostume [ guibar; guiimage (concatword "packages/plexus/models/thumbs/" (get $costumenames [[@@guirollovername]])) $guirolloveraction 4 1 "packages/plexus/dist/tc_logo.jpg"];'
1632 }
1647 }
1648 }
1649 }
1651 guitext += 'guitab "Upload"; guifield costume_push_name [] \n guibutton [Import Costume] [remotesend pushCostume $costume_push_name] \n ] '
1654 }
1656 println "name $name dir $dirId"
1664 }
1665 return
1666 }
1671 costume = dirId
1675 println "USE COSTUME $name ($costumeDir)"
1680 })
1681 }
1682 }
1685 }
1687 //println "Going to clear players"
1691 }
1695 exec {
1697 }
1698 return topic
1699 }
1702 exec {
1704 }
1705 }
1713 cachedPlayerLocations = [:]
1714 println "CONNECTING TO WORLD: $map.name ($map.id)"
1718 }
1721 exec {
1722 mapTopic = topic
1727 }
1728 },
1730 },
1734 }))
1735 }
1738 cachedPlayerLocations = [:]
1744 }
1745 }
1746 }
1748 }
1750 println "pushMap: [$nameArgs]"
1759 }
1760 println "1"
1765 transmitSetCloudProperty("${privateMap == '1' ? 'privateMap' : 'map'}/$topic", new JSONWriter().write([dir: id, name: name]))
1766 },
1768 exec {
1771 }
1772 })
1775 println "PLEXUS"
1778 println "store"
1781 println "sauer"
1782 def prefix = (new File(mapname).parent ? new File(sauerDir, "packages/$mapname") : new File(sauerDir, "packages/base/$mapname")).getAbsolutePath()
1790 println "FOUND GROOVY FILE: $it"
1792 }
1795 }
1798 }
1801 }
1802 println "store"
1804 }
1807 }
1808 }
1810 ids = ids as Set
1815 }
1816 }
1817 }
1821 println "bindPortal: portal_$id = ${getMapName(getMapEntry(topic))}"
1824 }
1825 }
1827 println "portals: $portals, id: $id, portals[id]: ${portals[id]}"
1830 }
1831 }
1833 def triggers = [] as Set
1837 }
1841 println "createPortal portal_$trigger = $name; portal $trigger"
1845 }
1847 def cfg = new File(mapname ==~ '.*/.*' ? new File(sauerDir, "packages") : new File(sauerDir, "packages/base"), mapname + ".cfg")
1856 }
1857 }
1863 }
1865 }
1867 }
1871 def values = [:]
1872 def format = []
1876 }
1882 }
1886 }
1887 }
1892 }
1893 }
1899 }
1900 }
1901 exec {
1904 }
1905 }
1906 }
1913 }
1914 }
1915 exec {
1919 }
1920 }
1921 }
1927 }
1928 }
1929 exec {
1932 }
1933 }
1934 }
1941 }
1942 }
1943 exec {
1947 }
1948 }
1949 }
1950 }