diff --git a/AlgebraicDataflowArchitectureModel/.classpath b/AlgebraicDataflowArchitectureModel/.classpath
new file mode 100644
index 0000000..3e99697
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/.classpath
@@ -0,0 +1,12 @@
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/AlgebraicDataflowArchitectureModel/.gitignore b/AlgebraicDataflowArchitectureModel/.gitignore
new file mode 100644
index 0000000..3e2fcc7
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/.gitignore
@@ -0,0 +1 @@
+/bin/
diff --git a/AlgebraicDataflowArchitectureModel/.project b/AlgebraicDataflowArchitectureModel/.project
new file mode 100644
index 0000000..15e3364
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/.project
@@ -0,0 +1,17 @@
+
+
+ AlgebraicDataflowArchitectureModel
+
+
+
+
+
+ org.eclipse.jdt.core.javabuilder
+
+
+
+
+
+ org.eclipse.jdt.core.javanature
+
+
diff --git a/AlgebraicDataflowArchitectureModel/.settings/org.eclipse.jdt.core.prefs b/AlgebraicDataflowArchitectureModel/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..263a512
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,15 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.methodParameters=do not generate
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=13
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=13
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=warning
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=13
diff --git a/AlgebraicDataflowArchitectureModel/dtram.log b/AlgebraicDataflowArchitectureModel/dtram.log
new file mode 100644
index 0000000..8a64fa5
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/dtram.log
@@ -0,0 +1,44 @@
+3月 15, 2024 3:10:09 午後 application.ApplicationWindow
+情報: launched
+3月 15, 2024 3:10:14 午後 application.actions.AbstractSystemAction actionPerformed
+情報: 開く
+3月 15, 2024 3:10:33 午後 application.views.NavigationWindow stageChanged
+情報: application.editor.stages.DataFlowModelingStage@3d463297
+3月 15, 2024 3:10:33 午後 application.views.NavigationWindow stageChanged
+情報: application.editor.stages.PushPullSelectionStage@37c62c43
+3月 15, 2024 3:29:48 午後 application.ApplicationWindow
+情報: launched
+3月 15, 2024 3:29:51 午後 application.actions.AbstractSystemAction actionPerformed
+情報: 開く
+3月 15, 2024 3:29:55 午後 application.views.NavigationWindow stageChanged
+情報: application.editor.stages.DataFlowModelingStage@3f75cd3f
+3月 15, 2024 3:29:55 午後 application.views.NavigationWindow stageChanged
+情報: application.editor.stages.PushPullSelectionStage@187ec296
+3月 15, 2024 3:29:59 午後 application.editor.stages.PushPullSelectionCellEditor stopEditing
+情報: PUSH
+3月 15, 2024 3:30:01 午後 application.editor.stages.PushPullSelectionCellEditor stopEditing
+情報: PUSH
+3月 15, 2024 3:30:03 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Double clicked
+3月 15, 2024 3:30:03 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Selecting Control-Flow (src, dst) = (updateGPS, longitude)
+3月 15, 2024 3:30:05 午後 application.editor.stages.ControlFlowDelegationStage$2 mouseReleased
+情報: Reset selection
+3月 15, 2024 3:30:07 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Double clicked
+3月 15, 2024 3:30:07 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Selecting Control-Flow (src, dst) = (longitude, mapLongitude)
+3月 15, 2024 3:30:07 午後 application.editor.stages.ControlFlowDelegationStage$2 mouseReleased
+情報: Reset selection
+3月 15, 2024 3:31:24 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Double clicked
+3月 15, 2024 3:31:24 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Selecting Control-Flow (src, dst) = (updateGPS, longitude)
+3月 15, 2024 3:31:25 午後 application.editor.stages.ControlFlowDelegationStage$2 mouseReleased
+情報: Reset selection
+3月 15, 2024 3:31:33 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Double clicked
+3月 15, 2024 3:31:33 午後 application.editor.stages.ControlFlowDelegationCellEditor startEditing
+情報: Selecting Control-Flow (src, dst) = (updateGPS, longitude)
+3月 15, 2024 3:31:39 午後 application.editor.stages.ControlFlowDelegationStage$2 mouseReleased
+情報: Reset selection
diff --git a/AlgebraicDataflowArchitectureModel/lib/jgraphx.jar b/AlgebraicDataflowArchitectureModel/lib/jgraphx.jar
new file mode 100644
index 0000000..72b5aae
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/lib/jgraphx.jar
Binary files differ
diff --git a/AlgebraicDataflowArchitectureModel/models/Algolike.model b/AlgebraicDataflowArchitectureModel/models/Algolike.model
new file mode 100644
index 0000000..aa943d3
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Algolike.model
@@ -0,0 +1,113 @@
+init {
+ deck := nil
+ handsA := nil
+ handsB := nil
+ guessA := 0
+ guessB := 0
+}
+channel targetAInput{
+ out targetA(t:Int, setTargetA(a:Int)) == a
+}
+channel targetBInput{
+ out targetB(t:Int, setTargetB(b:Int)) == b
+}
+channel attackerAInput{
+ out attackerA(t:Int, setAttackerA(a:Int)) == a
+}
+channel attackerBInput{
+ out attackerB(t:Int, setAttackerB(b:Int)) == b
+}
+channel guessAInput{
+ out guessA(t:Int, setGuessA(a:Int)) == a
+}
+channel guessBInput{
+ out guessB(t:Int, setGuessB(b:Int)) == b
+}
+channel addDeck{
+ out deck(d:List, addCard(num:Integer)) == cons(tuple(num, false), d)
+}
+
+channel drawAInput{
+
+ ref targetA(t:Int, drawAndAttackA(t, g, b))
+ ref guessA(g:Int, drawAndAttackA(t, g, b))
+ ref handsB(b:List, drawAndAttackA(t, g, b))
+ out resultByDrawingA(sda:Tuple, drawAndAttackA(t, g, b)) == tuple(eq(fst(get(b, t)), g), t)
+}
+
+channel inputDrawArgsA{
+ in resultByDrawingA(sda:Tuple, drawA(sucTrg, d)) == sucTrg
+ ref deck(d:List, drawA(sucTrg, d))
+
+ out handsA(outA:List, drawA(sucTrg, d)) == if(fst(sucTrg),
+ sortByKey(cons(tuple(fst(head(d)),false), outA)),
+ sortByKey(cons(tuple(fst(head(d)), true), outA)))
+
+ out handsB(outB:List, drawA(sucTrg, d)) == if(fst(sucTrg),
+ set(outB, snd(sucTrg), tuple(fst(get(outB, snd(sucTrg))), true)),
+ outB)
+ out deck(t:List, drawA(sucTrg, d)) == tail(t)
+}
+
+channel selectAInput{
+ ref attackerA(a:Int, selectAndAttackA(a, t, g, b))
+ ref targetA(t:Int, selectAndAttackA(a, t, g, b))
+ ref guessA(g:Int, selectAndAttackA(a, t, g, b))
+ ref handsB(b:List, selectAndAttackA(a, t, g, b))
+ out resultBySelectingA(ssa:Tuple, selectAndAttackA(a, t, g, b)) == tuple(eq(fst(get(b, t)), g), t, a)
+}
+channel inputSelectArgA{
+ in resultBySelectingA(ssa, selectA(sucTrgAtk)) == sucTrgAtk
+ out handsA(outA, selectA(sucTrgAtk)) == if(fst(sucTrgAtk),
+ outA,
+ set(outA, snd(snd(sucTrgAtk)), tuple(fst(get(outA, snd(snd(sucTrgAtk)))), true)))
+ out handsB(outB, selectA(sucTrgAtk)) == if(fst(sucTrgAtk),
+ set(outB, fst(snd(sucTrgAtk)), tuple(fst(get(outB, fst(snd(sucTrgAtk)))), true)),
+ outB)
+}
+channel drawBInput{
+ ref targetB(t:Int, drawAndAttackB(t, g, a))
+ ref guessB(g:Int, drawAndAttackB(t, g, a))
+ ref handsA(a:List, drawAndAttackB(t, g, a))
+ out resultByDrawingB(sdb:Tuple, drawAndAttackB(t, g, a)) == tuple(eq(fst(get(a, t)), g), t)
+}
+
+channel inputDrawArgsB{
+ in resultByDrawingB(sdb:Tuple, drawB(sucTrg, d)) == sucTrg
+ ref deck(d:List, drawB(sucTrg, d))
+
+ out handsB(outB:List, drawB(sucTrg, d)) == if(fst(sucTrg),
+ sortByKey(cons(tuple(fst(head(d)),false), outB)),
+ sortByKey(cons(tuple(fst(head(d)), true), outB)))
+
+ out handsA(outA:List, drawB(sucTrg, d)) == if(fst(sucTrg),
+ set(outA, snd(sucTrg), tuple(fst(get(outA, snd(sucTrg))), true)),
+ outA)
+ out deck(t:List, drawB(sucTrg, d)) == tail(t)
+}
+
+channel selectBInput{
+ ref attackerB(atk:Int, selectAndAttackB(atk, t, g, a))
+ ref targetB(t:Int, selectAndAttackB(atk, t, g, a))
+ ref guessB(g:Int, selectAndAttackB(atk, t, g, a))
+ ref handsA(a:List, selectAndAttackB(atk, t, g, a))
+ out resultBySelectingB(ssb:Tuple, selectAndAttackB(atk, t, g, a)) == tuple(eq(fst(get(a, t)), g), t, atk)
+}
+channel inputSelectArgB{
+ in resultBySelectingB(ssb, selectB(sucTrgAtk)) == sucTrgAtk
+ out handsB(outB, selectB(sucTrgAtk)) == if(fst(sucTrgAtk),
+ outB,
+ set(outB, snd(snd(sucTrgAtk)), tuple(fst(get(outB, snd(snd(sucTrgAtk)))), true)))
+ out handsA(outA, selectB(sucTrgAtk)) == if(fst(sucTrgAtk),
+ set(outA, fst(snd(sucTrgAtk)), tuple(fst(get(outA, fst(snd(sucTrgAtk)))), true)),
+ outA)
+}
+
+channel judgeA{
+ in handsA(a:List, judge(j)) == j
+ out loseA(la:Bool, judge(j)) == eq(length(extractFaceDown(j)), 0)
+}
+channel judgeB{
+ in handsB(b:List, judge(j)) == j
+ out loseB(lb:Bool, judge(j)) == eq(length(extractFaceDown(j)), 0)
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/Audio.dtram b/AlgebraicDataflowArchitectureModel/models/Audio.dtram
new file mode 100644
index 0000000..66862ef
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Audio.dtram
@@ -0,0 +1,33 @@
+model {
+channel CIO3 {
+ out BGMVolume(b: Double, setBGM(b2)) == b2
+}
+channel CIO2 {
+ out soundVolume(s: Double, setSound(s2)) == s2
+}
+channel CIO1 {
+ out audioVolume(a: Double, setAudio(a2)) == a2
+}
+channel C1 {
+ in audioVolume(a, calc(a2, s2)) == a2
+ in soundVolume(s, calc(a2, s2)) == s2
+ out outputSoundVolume(os, calc(a2, s2)) == a2 * s2
+}
+channel C2 {
+ in audioVolume(a, calc(a2, b2)) == a2
+ in BGMVolume(b, calc(a2, b2)) == b2
+ out outputBGMVolume(ob, calc(a2, b2)) == a2 * b2
+}
+}
+geometry {
+ node r soundVolume:220,140,80,30
+ node r audioVolume:220,280,80,30
+ node r outputSoundVolume:650,190,80,30
+ node r BGMVolume:220,420,80,30
+ node r outputBGMVolume:650,340,80,30
+ node ioc CIO3:100,420,30,30
+ node ioc CIO2:100,140,30,30
+ node ioc CIO1:100,280,30,30
+ node c C1:530,190,30,30
+ node c C2:530,340,30,30
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/Base.model b/AlgebraicDataflowArchitectureModel/models/Base.model
new file mode 100644
index 0000000..2236c0c
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Base.model
@@ -0,0 +1,13 @@
+channel CIO{
+ out r1(x1:Int, set1(y1:Int)) == y1
+ out r1(x1, e) == x1
+}
+channel CIO2{
+ out r2(x2:Int, set2(y2:Int)) == y2
+ out r2(x2, e) == x2
+}
+channel C1{
+ in r1(x1, update(x1:Int, y1:Int, x2:Int, y2:Int)) == y1
+ in r2(x2, update(x1, y1, x2, y2)) == y2
+ out r3(x3:Int, update(x1, y1, x2, y2)) == x1 + y1 + x2 + y2
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/Clock.dtram b/AlgebraicDataflowArchitectureModel/models/Clock.dtram
new file mode 100644
index 0000000..ae2169e
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Clock.dtram
@@ -0,0 +1,27 @@
+model {
+ channel CIO1 {
+ out min(m: Double, tick) == mod(m + 1, 60)
+ }
+ channel Clock {
+ in min(m, update(m2)) == m2
+ out hour(h: Double, update(m2)) == if(eq(m2, 0), mod(h + 1, 24), h)
+ }
+ channel MinUpdate {
+ in min(m, update(m2)) == m2
+ out min_ang(m_ang: Double, update(m2)) == m2 / 30 * PI
+ }
+ channel HourUpdate {
+ in hour(h, update(h2)) == h2
+ out hour_ang(h_ang: Double, update(h2)) == h2 / 6 * PI
+ }
+}
+geometry {
+ node c HourUpdate:520,340,30,30
+ node c MinUpdate:520,100,30,30
+ node c Clock:280,220,30,30
+ node r min_ang:670,100,80,30
+ node r min:250,100,80,30
+ node r hour:270,340,80,30
+ node r hour_ang:680,340,80,30
+ node ioc CIO1:100,100,30,30
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/CustomerOffice.model b/AlgebraicDataflowArchitectureModel/models/CustomerOffice.model
new file mode 100644
index 0000000..f140bff
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/CustomerOffice.model
@@ -0,0 +1,33 @@
+channel C_CustomerAOff_In {
+ out customerA_off(c:String, setOff(x)) == x
+ out customerA_off(c, e) == c
+}
+
+channel C_CustomerBOff_In {
+ out customerB_off(c:String, setOff(x)) == x
+ out customerB_off(c, e) == c
+}
+
+channel C_CompanyC1Add_In {
+ out companyC1_add(a:String, setAdd(y)) == y
+ out companyC1_add(a, e) == a
+}
+
+channel C_CompanyC2Add_In {
+ out companyC2_add(a:String, setAdd(y)) == y
+ out companyC2_add(a, e) == a
+}
+
+channel CA {
+ in customerA_off(c, sync(z, u, v)) == z
+ in companyC1_add(a1, sync(z, u, v)) == u
+ in companyC2_add(a2, sync(z, u, v)) == v
+ out customerA_add(a3:String, sync(z, u, v)) == if(eq(z, C1), u, if(eq(z, C2), v, null))
+}
+
+channel CB {
+ in customerB_off(c, sync(z, u, v)) == z
+ in companyC1_add(a1, sync(z, u, v)) == u
+ in companyC2_add(a2, sync(z, u, v)) == v
+ out customerB_add(a3:String, sync(z, u, v)) == if(eq(z, C1), u, if(eq(z, C2), v, null))
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/Game.model b/AlgebraicDataflowArchitectureModel/models/Game.model
new file mode 100644
index 0000000..bc90ba4
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Game.model
@@ -0,0 +1,32 @@
+channel CIO {
+ out force(f:Double, action(x:Double)) == x
+ out time(t:Double, action(x)) == t + 0.01
+ out force(f, e) == x
+ out time(t, e) == t + 0.01
+}
+
+channel CIO2 {
+ out velocity(v:Double, setVel(x:Double)) == x
+ out velocity(v, e) == x
+}
+
+channel CIO3 {
+ out mass(m:Double, setMass(x:Double)) == x
+ out mass(m, e) == m
+}
+
+channel C1 {
+ in force(f, update1(y, z)) == y
+ in mass(m, update1(y, z)) == z
+ out acceleration(a: Double, update1(y, z)) == y / z
+}
+
+channel C2 {
+ in acceleration(a, update2(z)) == z
+ out velocity(v:Double, update2(z)) == v + 0.01 * z
+}
+
+channel C3 {
+ in velocity(v, update3(u)) == u
+ out position(p:Double, update3(u)) == p + 0.01 * u
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/JumpGame.model b/AlgebraicDataflowArchitectureModel/models/JumpGame.model
new file mode 100644
index 0000000..4c24a56
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/JumpGame.model
@@ -0,0 +1,71 @@
+init {
+ force := pair(0.0, 0.0)
+ time := 0.0
+ movex := 0.0
+ movey := 0.0
+ mass := 1.0
+ ground := true
+ acceleration := pair(0.0, 0.0)
+ velocity := pair(0.0, 0.0)
+ onground := true
+ position := pair(0.0, 0.0)
+ clear := false
+ gameover := false
+}
+channel CIO {
+ out force(f:Pair, gravity(y:Double)) == pair(0.0, y)
+ out time(t:Double, gravity(y)) == t + 0.01
+}
+channel CIO2 {
+ out movex(x:Double, run(x2:Double)) == x2
+}
+channel CIO3 {
+ out movey(y:Double, jump(y2:Double)) == y2
+}
+channel CIO4 {
+ out mass(m:Double, setMass(x:Double)) == x
+}
+channel CIO5 {
+ out ground(g:Bool, openHole) == false
+ out ground(g, closeHole) == true
+}
+channel C1 {
+ ref onground(o, update1(f2, m2, o))
+ in force(f, update1(f2, m2, o)) == f2
+ in mass(m, update1(f2, m2, o)) == m2
+ out acceleration(a:Pair, update1(f2, m2, o)) == if(o, pair(left(f2) / m2, 0.0), pair(left(f2) / m2, right(f2) / m2))
+}
+channel C2 {
+ ref onground(o, update3(a2, o))
+ in acceleration(a, update3(a2, o)) == a2
+ out velocity(v:Pair, update3(a2, o)) == if(and(o, lt(right(v), 0.0)),
+ pair(left(v) + 0.01 * left(a2), 0.0),
+ pair(left(v) + 0.01 * left(a2), right(v) + 0.01 * right(a2)))
+}
+channel C3 {
+ ref onground(o, update4(x2, o))
+ in movex(x, update4(x2, o)) == x2
+ out velocity(v:Pair, update4(x2, o)) == if(o, pair(x2, right(v)), v)
+}
+channel C4 {
+ ref onground(o, update5(x2, o))
+ in movey(y, update5(y2, o)) == y2
+ out velocity(v:Pair, update5(y2, o)) == if(o, pair(left(v), y2), v)
+}
+channel C5 {
+ in velocity(v, update6(v2, g)) == v2
+ ref ground(g, update6(v2, g))
+ out position(p:Pair, update6(v2, g)) == if(and(eq(g, true), lt(right(p) + 0.01 * right(v2), 0.0)),
+ pair(left(p) + 0.01 * left(v2), 0.0),
+ pair(left(p) + 0.01 * left(v2), right(p) + 0.01 * right(v2)))
+}
+channel C6 {
+ in position(p, update2(p2, g2)) == p2
+ in ground(g, update2(p2, g2)) == g2
+ out onground(o:Bool, update2(p2, g2)) == and(eq(g2, true), le(right(p2), 0.0))
+}
+channel C7 {
+ in position(p, update7(p2)) == p2
+ out clear(c:Bool, update7(p2)) == if(gt(left(p2), 100.0), true, false)
+ out gameover(go:Bool, update7(p2)) == if(lt(right(p2), -1.0), true, false)
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/Kinetics.model b/AlgebraicDataflowArchitectureModel/models/Kinetics.model
new file mode 100644
index 0000000..5218206
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Kinetics.model
@@ -0,0 +1,20 @@
+channel CIO {
+ out force(f:Double, action(x)) == x
+ out time(t:Double, action(x)) == t + 0.01
+}
+
+channel C1 {
+ in force(f, update1(y, m)) == y
+ in mass(m, update1(y, m)) == m
+ out acceleration(a:Double, update1(y, m)) == y / m
+}
+
+channel C2 {
+ in acceleration(a, update2(z)) == z
+ out velocity(v:Double, update2(z)) == v + 0.01 * z
+}
+
+channel C3 {
+ in velocity(v, update3(u)) == u
+ out position(p:Double, update3(u)) == p + 0.01 * u
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/Map.dtram b/AlgebraicDataflowArchitectureModel/models/Map.dtram
new file mode 100644
index 0000000..b1fe577
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Map.dtram
@@ -0,0 +1,23 @@
+model {
+ channel GPS_In {
+ out longitude(prev_long: Double, updateGPS(cur_long, cur_lat)) == cur_long
+ out latitude(prev_lat: Double, updateGPS(cur_long, cur_lat)) == cur_lat
+ }
+ channel LongUpdate {
+ in longitude(prev_long, updateLong(cur_long)) == cur_long
+ out mapLongitude(prev_mapLong, updateLong(cur_long)) == cur_long
+ }
+ channel LatUpdate {
+ in latitude(prev_lat, updateLat(cur_lat)) == cur_lat
+ out mapLatitude(prev_mapLat, updateLat(cur_lat)) == cur_lat
+ }
+}
+geometry {
+ node r mapLatitude:580,310,80,30
+ node r latitude:190,310,80,30
+ node r mapLongitude:580,170,80,30
+ node r longitude:190,170,80,30
+ node ioc GPS_In:40,60,30,30
+ node c LongUpdate:410,170,30,30
+ node c LatUpdate:410,310,30,30
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/Map.model b/AlgebraicDataflowArchitectureModel/models/Map.model
new file mode 100644
index 0000000..2ea85ff
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Map.model
@@ -0,0 +1,14 @@
+channel GPS_In {
+ out longitude(prev_long: Double, updateGPS(cur_long, cur_lat)) == cur_long
+ out latitude(prev_lat: Double, updateGPS(cur_long, cur_lat)) == cur_lat
+}
+
+channel LongUpdate {
+ in longitude(prev_long, updateLong(cur_long)) == cur_long
+ out mapLongitude(prev_mapLong, updateLong(cur_long)) == cur_long
+}
+
+channel LatUpdate {
+ in latitude(prev_lat, updateLat(cur_lat)) == cur_lat
+ out mapLatitude(prev_mapLat, updateLat(cur_lat)) == cur_lat
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/POS.dtram b/AlgebraicDataflowArchitectureModel/models/POS.dtram
new file mode 100644
index 0000000..53eb13d
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/POS.dtram
@@ -0,0 +1,27 @@
+model {
+channel CIO {
+ out payment(p:Int, purchase(x:Int)) == x
+}
+channel C3 {
+ in history(h, update3(u)) == u
+ out total(t:Int, update3(u)) == sum(u)
+}
+channel C1 {
+ in payment(p, update1(y)) == y
+ out points(l:Int, update1(y)) == floor(y * 0.05)
+}
+channel C2 {
+ in payment(p, update2(z)) == z
+ out history(h:List, update2(z)) == cons(z, h)
+}
+}
+geometry {
+ node c C3:850,90,30,30
+ node c C1:500,20,30,30
+ node c C2:500,90,30,30
+ node r total:1000,90,80,30
+ node r payment:300,55,80,30
+ node r history:650,90,80,30
+ node r points:650,20,80,30
+ node ioc CIO:150,55,30,30
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/POS.model b/AlgebraicDataflowArchitectureModel/models/POS.model
new file mode 100644
index 0000000..fc941ca
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/POS.model
@@ -0,0 +1,15 @@
+channel CIO {
+ out payment(p:Int, purchase(x:Int)) == x
+}
+channel C3 {
+ in history(h, update3(u)) == u
+ out total(t:Int, update3(u)) == sum(u)
+}
+channel C1 {
+ in payment(p, update1(y)) == y
+ out points(l:Int, update1(y)) == floor(y * 0.05)
+}
+channel C2 {
+ in payment(p, update2(z)) == z
+ out history(h:List, update2(z)) == cons(z, h)
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/POS2.model b/AlgebraicDataflowArchitectureModel/models/POS2.model
new file mode 100644
index 0000000..6ae676d
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/POS2.model
@@ -0,0 +1,14 @@
+channel CIO {
+ out payment(p:Int, purchase(x:Int)) == x
+}
+
+channel C1 {
+ in payment(p1, update1(y)) == y
+ out points(l:Int, update1(y)) == floor(y * 0.05)
+}
+
+channel C2 {
+ in payment(p1, update2(z)) == z
+ out history(h:List, update2(z)) == cons(z, h)
+ out total(t:Int, update2(z)) == z + t
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/SSDStore.dtram b/AlgebraicDataflowArchitectureModel/models/SSDStore.dtram
new file mode 100644
index 0000000..e226ec0
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/SSDStore.dtram
@@ -0,0 +1,33 @@
+model {
+ channel capacity_In {
+ out capacity(prev_capacity:Int, setCapacity(cur_capacity)) == cur_capacity
+ }
+ channel price_In {
+ out price(prev_price:Int, setPrice(cur_price)) == cur_price
+ }
+ channel siteA_Add {
+ out siteA(prev_products:List, addProductToSiteA(price:Int, capacity:Int)) == cons({"price": price, "capacity": capacity}, prev_products)
+ }
+ channel capacity_Update {
+ in siteA(prev_products:List, updateList(cur_products, cur_capacity)) == cur_products
+ in capacity(prev_capacity:Int, updateList(cur_products, cur_capacity)) == cur_capacity
+ out itemsByCapacity(prev_items:List, updateList(cur_products, cur_capacity)) == selectGE(cur_products, "capacity", cur_capacity)
+ }
+ channel price_Update {
+ in siteA(prev_products:List, updateList(cur_products, cur_price)) == cur_products
+ in price(prev_price:Int, updateList(cur_products, cur_price)) == cur_price
+ out itemsByPrice(prev_items:List, updateList(cur_products, cur_price)) == selectLE(cur_products, "price", cur_price)
+ }
+}
+geometry {
+ node r price:250,40,80,30
+ node r itemsByPrice:650,110,80,30
+ node r itemsByCapacity:650,280,80,30
+ node r siteA:250,200,80,30
+ node r capacity:250,370,80,30
+ node ioc capacity_In:100,370,30,30
+ node ioc price_In:100,40,30,30
+ node ioc siteA_Add:100,200,30,30
+ node c capacity_Update:500,280,30,30
+ node c price_Update:500,110,30,30
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/SSDStore.model b/AlgebraicDataflowArchitectureModel/models/SSDStore.model
new file mode 100644
index 0000000..e8696fe
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/SSDStore.model
@@ -0,0 +1,23 @@
+channel capacity_In {
+ out capacity(prev_capacity:Int, setCapacity(cur_capacity)) == cur_capacity
+}
+
+channel price_In {
+ out price(prev_price:Int, setPrice(cur_price)) == cur_price
+}
+
+channel siteA_Add {
+ out siteA(prev_products:List, addProductToSiteA(price:Int, capacity:Int)) == cons({"price": price, "capacity": capacity}, prev_products)
+}
+
+channel capacity_Update {
+ in siteA(prev_products:List, updateList(cur_products, cur_capacity)) == cur_products
+ in capacity(prev_capacity:Int, updateList(cur_products, cur_capacity)) == cur_capacity
+ out itemsByCapacity(prev_items:List, updateList(cur_products, cur_capacity)) == selectGE(cur_products, "capacity", cur_capacity)
+}
+
+channel price_Update {
+ in siteA(prev_products:List, updateList(cur_products, cur_price)) == cur_products
+ in price(prev_price:Int, updateList(cur_products, cur_price)) == cur_price
+ out itemsByPrice(prev_items:List, updateList(cur_products, cur_price)) == selectLE(cur_products, "price", cur_price)
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/SamplePULL.dtram b/AlgebraicDataflowArchitectureModel/models/SamplePULL.dtram
new file mode 100644
index 0000000..0c06ae8
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/SamplePULL.dtram
@@ -0,0 +1,21 @@
+model {
+ channel setAChannel {
+ out a(aValue:Int, setA(value)) == value
+ }
+ channel outBChannel {
+ in a(aValue:Int, calcB(aValue)) == aValue
+ out b(bValue:Int ,calcB(aValue)) == aValue * 2
+ }
+ channel outCChannel {
+ in a(aValue:Int, calcC(aValue)) == aValue
+ out c(cValue:Int, calcC(aValue)) == aValue + 1
+ }
+}
+geometry {
+ node r a:250,170,80,30
+ node r b:580,80,80,30
+ node r c:590,280,80,30
+ node ioc setAChannel:90,170,30,30
+ node c outBChannel:430,80,30,30
+ node c outCChannel:440,280,30,30
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/SamplePUSH.dtram b/AlgebraicDataflowArchitectureModel/models/SamplePUSH.dtram
new file mode 100644
index 0000000..c07e68b
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/SamplePUSH.dtram
@@ -0,0 +1,15 @@
+model {
+ channel setAChannel {
+ out a(aValue:Int, setA(value)) == value
+ }
+ channel updateBChannel {
+ in a(aValue:Int, updateB(aValue)) == aValue
+ out b(bValue:Int, updateB(aValue)) == bValue + aValue
+ }
+}
+geometry {
+ node r a:270,270,80,30
+ node r b:660,270,80,30
+ node ioc setAChannel:90,240,100,90
+ node c updateBChannel:460,240,100,90
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/StockManagement.model b/AlgebraicDataflowArchitectureModel/models/StockManagement.model
new file mode 100644
index 0000000..b133f44
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/StockManagement.model
@@ -0,0 +1,50 @@
+init {
+ stock := nil
+ shortage := nil
+}
+
+channel CIO_enter {
+ out arrival(s:Tuple, arrive(item:Str, num:Int)) == tuple(item, num)
+}
+
+channel CIO_req {
+ out request(r:Tuple, req(item:Str, num:Int)) == tuple(item, num)
+}
+
+channel C1 {
+ in arrival(ar, update1(ar2, st)) == ar2
+ ref stock(st:Map, update1(ar2, st))
+ out available(av:Tuple, update1(ar2, st)) == tuple(fst(ar2), snd(ar2) + lookup(st, fst(ar2)))
+}
+
+channel C2 {
+ in available(av, update2(av2, sh)) == av2
+ ref shortage(sh, update2(av2, sh))
+ out deriver(dr:Tuple, update2(av2, sh)) == if(ge(snd(av2), lookup(sh, fst(av2))),
+ tuple(fst(av2), lookup(sh, fst(av2)), snd(av2) - lookup(sh, fst(av2))),
+ tuple(fst(av2), 0, snd(av2)))
+ out shortage(s, update2(av2, sh)) == if(ge(snd(av2), lookup(s, fst(av2))),
+ insert(s, fst(av2), 0),
+ s)
+}
+
+channel C3 {
+ in deriver(dr, update3(dr2)) == dr2
+ out stock(st, update3(dr2)) == insert(st, fst(dr2), snd(snd(dr2)))
+}
+
+channel C4 {
+ in deriver(dr, update4(dr2)) == dr2
+ out shipping(sp:Tuple, update4(dr2)) == tuple(fst(dr2), fst(snd(dr2)))
+}
+
+channel C5 {
+ in request(rq, update5(rq2, st)) == rq2
+ ref stock(st, update5(rq2, st))
+ out deriver(dr, update5(rq2, st)) == if(ge(lookup(st, fst(rq2)), snd(rq2)),
+ tuple(fst(rq2), snd(rq2), lookup(st, fst(rq2)) - snd(rq2)),
+ tuple(fst(rq2), 0, lookup(st, fst(rq2))))
+ out shortage(sh, update5(rq2, st)) == if(ge(lookup(st, fst(rq2)), snd(rq2)),
+ sh,
+ insert(sh, fst(rq2), lookup(sh, fst(rq2)) + snd(rq2)))
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/TravelDistance.model b/AlgebraicDataflowArchitectureModel/models/TravelDistance.model
new file mode 100644
index 0000000..a0c8fe2
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/TravelDistance.model
@@ -0,0 +1,13 @@
+channel CX {
+ out pos_x(prev_x: Double, setX(cur_x: Double)) == cur_x
+}
+
+channel CY {
+ out pos_y(prev_y: Double, setY(cur_y: Double)) == cur_y
+}
+
+channel C {
+ in pos_x(prev_x, move(dx, dy)) == prev_x + dx
+ in pos_y(prev_y, move(dx, dy)) == prev_y + dy
+ out dist(prev_d, move(dx, dy)) == prev_d + sqrt(dx * dx + dy * dy)
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/Triangle.model b/AlgebraicDataflowArchitectureModel/models/Triangle.model
new file mode 100644
index 0000000..ebfe6b4
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Triangle.model
@@ -0,0 +1,13 @@
+channel cio1 {
+ out base(x: Double, setBase(x2)) == x2
+}
+
+channel cio2 {
+ out height(y: Double, setHeight(y2)) == y2
+}
+
+channel triangle {
+ in base(x, update(x2, y2)) == x2
+ in height(y, update(x2, y2)) == y2
+ out hypothenuse(z: Double, update(x2, y2)) == sqrt(x2 * x2 + y2 * y2)
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/Triangle2.model b/AlgebraicDataflowArchitectureModel/models/Triangle2.model
new file mode 100644
index 0000000..db775bd
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Triangle2.model
@@ -0,0 +1,13 @@
+channel cio1 {
+ out base(x: Double, setBase(x2)) == x2
+}
+
+channel cio2 {
+ out height(y: Double, setHeight(y2)) == y2
+}
+
+channel triangle {
+ in base(x, update: Tuple) == fst(update)
+ in height(y, update) == snd(update)
+ out hypothenuse(z: Double, update) == sqrt(fst(update) * fst(update) + snd(update) * snd(update))
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/Twitter.model b/AlgebraicDataflowArchitectureModel/models/Twitter.model
new file mode 100644
index 0000000..57de3b3
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/Twitter.model
@@ -0,0 +1,47 @@
+channel a_Tweet {
+ out a_tweets(l:List, a_tweet(t:Str, time:Long)) == cons(tuple(time, t), l)
+}
+
+channel a_Follow {
+ out a_following(f:List, a_follow(u:Int)) == cons(u, f)
+}
+
+channel a_Home {
+ in a_tweets(la1, update_a(f2, la2, lb2, lc2)) == la2
+ in b_tweets(lb1, update_a(f2, la2, lb2, lc2)) == lb2
+ in c_tweets(lc1, update_a(f2, la2, lb2, lc2)) == lc2
+ in a_following(f, update_a(f2, la2, lb2, lc2)) == f2
+ out a_timeline(t:List, update_a(f2, la2, lb2, lc2)) == merge(la2, if(contains(f2,2), merge(lb2, if(contains(f2,3), lc2, nil)), if(contains(f2,3), lc2, nil)))
+}
+
+channel b_Tweet {
+ out b_tweets(l:List, b_tweet(t:Str, time:Long)) == cons(tuple(time, t), l)
+}
+
+channel b_Follow {
+ out b_following(f:List, b_follow(u:Int)) == cons(u, f)
+}
+
+channel b_Home {
+ in a_tweets(la1, update_b(f2, la2, lb2, lc2)) == la2
+ in b_tweets(lb1, update_b(f2, la2, lb2, lc2)) == lb2
+ in c_tweets(lc1, update_b(f2, la2, lb2, lc2)) == lc2
+ in b_following(f, update_b(f2, la2, lb2, lc2)) == f2
+ out b_timeline(t:List, update_b(f2, la2, lb2, lc2)) == merge(lb2, if(contains(f2,1), merge(la2, if(contains(f2,3), lc2, nil)), if(contains(f2,3), lc2, nil)))
+}
+
+channel c_Tweet {
+ out c_tweets(l:List, c_tweet(t:Str, time:Long)) == cons(tuple(time, t), l)
+}
+
+channel c_Follow {
+ out c_following(f:List, c_follow(u:Int)) == cons(u, f)
+}
+
+channel c_Home {
+ in a_tweets(la1, update_c(f2, la2, lb2, lc2)) == la2
+ in b_tweets(lb1, update_c(f2, la2, lb2, lc2)) == lb2
+ in c_tweets(lc1, update_c(f2, la2, lb2, lc2)) == lc2
+ in c_following(f, update_c(f2, la2, lb2, lc2)) == f2
+ out c_timeline(t:List, update_c(f2, la2, lb2, lc2)) == merge(lc2, if(contains(f2,1), merge(la2, if(contains(f2,2), lb2, nil)), if(contains(f2,2), lb2, nil)))
+}
diff --git a/AlgebraicDataflowArchitectureModel/models/WOS.dtram b/AlgebraicDataflowArchitectureModel/models/WOS.dtram
new file mode 100644
index 0000000..bbffde1
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/WOS.dtram
@@ -0,0 +1,25 @@
+model {
+channel CIO2 {
+ out highest(h:Double, reset(v)) == v
+}
+channel CIO1 {
+ out temp_f(p:Double, observe(x)) == x
+}
+channel C1{
+ in temp_f(q:Double, conversion(y)) == y
+ out temp_c(r:Double, conversion(z)) == (z-32) / 1.8
+}
+channel C2{
+ in temp_f(q:Double, update(y)) == y
+ out highest(h:Double, update(z)) == if(gt(z, h), z, h)
+}
+}
+geometry {
+ node c C1:500,200,30,30
+ node c C2:500,100,30,30
+ node r highest:650,100,80,30
+ node r temp_c:650,200,80,30
+ node r temp_f:250,100,80,30
+ node ioc CIO2:100,300,30,30
+ node ioc CIO1:100,100,30,30
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/models/WeatherObservationSystem.model b/AlgebraicDataflowArchitectureModel/models/WeatherObservationSystem.model
new file mode 100644
index 0000000..f16d38f
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/models/WeatherObservationSystem.model
@@ -0,0 +1,14 @@
+channel CIO2 {
+ out highest(h:Double, reset(v)) == v
+}
+channel CIO1 {
+ out temp_f(p:Double, observe(x)) == x
+}
+channel C1{
+ in temp_f(q:Double, conversion(y)) == y
+ out temp_c(r:Double, conversion(z)) == (z-32) / 1.8
+}
+channel C2{
+ in temp_f(q:Double, update(y)) == y
+ out highest(h:Double, update(z)) == if(gt(z, h), z, h)
+}
diff --git a/AlgebraicDataflowArchitectureModel/resources/locales/en.properties b/AlgebraicDataflowArchitectureModel/resources/locales/en.properties
new file mode 100644
index 0000000..ac26d9b
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/resources/locales/en.properties
@@ -0,0 +1,49 @@
+# File
+file=File
+new=New
+open=Open
+save=Save
+saveAs=Save As...
+exit=Exit
+
+# New
+newModel=Model
+newResources=Resources...
+newChannel=Channel...
+newEventChannel=Event Channel
+newFormulaChannel=Formula Channel
+
+# Edit
+edit=Edit
+delete=Delete
+
+# Layout
+layout=Layout
+dagLayout=DAG Layout
+treeLayout=Tree Layout
+circleLayout=Circle Layout
+
+# View
+view=View
+zoomIn=Zoom In
+zoomOut=Zoom Out
+
+# Generate
+generate=Generate
+generateJava=Generate Plain Java Prototype
+generateJAX_RS=Generate Plain JAX-RS Prototype
+
+# Window
+window=Window
+showNavigation=Show Navigation
+showFlowLayer=Show Flow Layer
+
+# Navigation
+dataFlowModeling=Data-Flow Modeling
+pushpullSelection = PUSH/PULL Selection
+pushpullExtension = PUSH/PULL Extension
+
+# PopUp Actions
+changeCallOrder=Change Call Order
+insertMediator=Introduce Mediator
+dependsOnMediator=Depends On Mediator
diff --git a/AlgebraicDataflowArchitectureModel/resources/locales/ja.properties b/AlgebraicDataflowArchitectureModel/resources/locales/ja.properties
new file mode 100644
index 0000000..bc7288a
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/resources/locales/ja.properties
@@ -0,0 +1,49 @@
+# File
+file=\u30D5\u30A1\u30A4\u30EB
+new=\u65B0\u898F
+open=\u958B\u304F
+save=\u4FDD\u5B58
+saveAs=\u4E0A\u66F8\u304D\u4FDD\u5B58
+exit=\u9589\u3058\u308B
+
+# New
+newModel=\u30E2\u30C7\u30EB
+newResources=\u30EA\u30BD\u30FC\u30B9
+newChannel=\u30C1\u30E3\u30F3\u30CD\u30EB
+newEventChannel=\u30A4\u30D9\u30F3\u30C8\u30C1\u30E3\u30F3\u30CD\u30EB
+newFormulaChannel=\u30D5\u30A9\u30FC\u30DF\u30E5\u30E9\u30C1\u30E3\u30F3\u30CD\u30EB
+
+# Edit
+edit=\u7DE8\u96C6
+delete=\u524A\u9664
+
+# Layout
+layout=\u30EC\u30A4\u30A2\u30A6\u30C8
+dagLayout=DAG \u30EC\u30A4\u30A2\u30A6\u30C8
+treeLayout=\u30C4\u30EA\u30FC\u30EC\u30A4\u30A2\u30A6\u30C8
+circleLayout=\u30B5\u30FC\u30AF\u30EB\u30EC\u30A4\u30A2\u30A6\u30C8
+
+# View
+view=\u8868\u793A
+zoomIn=\u62E1\u5927
+zoomOut=\u7E2E\u5C0F
+
+# Generate
+generate=\u30D7\u30ED\u30C8\u30BF\u30A4\u30D7\u751F\u6210
+generateJava=Java\u30D7\u30ED\u30C8\u30BF\u30A4\u30D7\u306E\u751F\u6210
+generateJAX_RS=JAX-RS\u30D7\u30ED\u30C8\u30BF\u30A4\u30D7\u306E\u751F\u6210
+
+# Window
+window=\u30A6\u30A3\u30F3\u30C9\u30A6
+showNavigation=\u30CA\u30D3\u30B2\u30FC\u30B7\u30E7\u30F3
+showFlowLayer=\u30D5\u30ED\u30FC\u30EC\u30A4\u30E4\u30FC
+
+# Navigation
+dataFlowModeling=\u30C7\u30FC\u30BF\u30D5\u30ED\u30FC\u30E2\u30C7\u30EA\u30F3\u30B0
+pushpullSelection = PUSH/PULL\u306E\u9078\u629E
+pushpullExtension = PUSH/PULL\u306E\u62E1\u5F35
+
+# PopUp Actions
+changeCallOrder=\u547C\u3073\u51FA\u3057\u9806\u306E\u5909\u66F4
+insertMediator=\u4EF2\u4ECB\u8005\u30AA\u30D6\u30B8\u30A7\u30AF\u30C8\u306E\u5C0E\u5165
+dependsOnMediator=\u4EF2\u4ECB\u8005\u30AA\u30D6\u30B8\u30A7\u30AF\u30C8\u3078\u4F9D\u5B58
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/src/Main.java b/AlgebraicDataflowArchitectureModel/src/Main.java
new file mode 100644
index 0000000..54fdaf8
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/Main.java
@@ -0,0 +1,12 @@
+
+
+import application.ApplicationWindow;
+
+public class Main {
+
+ public static void main(String[] args) {
+ ApplicationWindow frame = new ApplicationWindow();
+ frame.setVisible(true);
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/algorithms/DataTransferModelAnalyzer.java b/AlgebraicDataflowArchitectureModel/src/algorithms/DataTransferModelAnalyzer.java
new file mode 100644
index 0000000..ff4c528
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/algorithms/DataTransferModelAnalyzer.java
@@ -0,0 +1,107 @@
+package algorithms;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.List;
+
+import models.*;
+import models.algebra.*;
+import models.dataConstraintModel.*;
+import models.dataFlowModel.*;
+
+/**
+ * Algorithms to analyze data transfer model.
+ *
+ * @author Nitta
+ *
+ */
+public class DataTransferModelAnalyzer {
+ /**
+ * Create data flow graph annotated with node attributes that indicate whether each resource state needs to be stored.
+ * @param model a data transfer model
+ * @return annotated data flow graph
+ */
+ static public DataFlowGraph createDataFlowGraphWithStateStoringAttribute(DataTransferModel model) {
+ DataFlowGraph graph = model.getDataFlowGraph();
+ Collection channels = new HashSet<>(model.getIOChannels());
+ channels.addAll(model.getChannels());
+ for (Channel channel: channels) {
+ for (ChannelMember member: ((DataTransferChannel) channel).getOutputChannelMembers()) {
+ boolean toBeStored = !member.getStateTransition().isRightUnary(); // The state does not need to be stored if the state transition function is right unary.
+ for (Node node: graph.getNodes()) {
+ if (((ResourceNode) node).getResource().equals(member.getResource())) {
+ setStoreAttribute((ResourceNode) node, toBeStored);
+ }
+ }
+ }
+ }
+ for (Node node: graph.getNodes()) {
+ HashSet inChannels = new HashSet<>();
+ for(Edge inEdge: ((ResourceNode) node).getInEdges()) {
+ inChannels.add(((DataFlowEdge) inEdge).getChannel());
+ }
+ if ((inChannels.size() > 1)) {
+ // If the resource has multiple input channels, then the state of the resource needs to be stored.
+ setStoreAttribute((ResourceNode) node, true);
+ } else if (((ResourceNode) node).getAttribute() == null) {
+ setStoreAttribute((ResourceNode) node, false);
+ }
+ }
+ return graph;
+ }
+
+ static private void setStoreAttribute(ResourceNode node, boolean toBeStored) {
+ NodeAttribute attr = node.getAttribute();
+ StoreAttribute store;
+ if (attr != null && attr instanceof NodeAttribute) {
+ store = (StoreAttribute) attr;
+ store.setNeeded(store.isNeeded() || toBeStored);
+ } else {
+ store = new StoreAttribute();
+ store.setNeeded(toBeStored);
+ node.setAttribute(store);
+ }
+ }
+
+ /**
+ * Annotate data flow graph with edge attributes that indicate selectable data transfer methods.
+ * @param graph a data flow graph
+ * @return annotated data flow graph
+ */
+ static public DataFlowGraph annotateWithSelectableDataTransferAttiribute(DataFlowGraph graph) {
+ List nodes = new ArrayList<>(graph.getNodes());
+ // set push only attributes
+ for (Node n: graph.getNodes()) {
+ if (nodes.contains(n) && ((StoreAttribute) ((ResourceNode) n).getAttribute()).isNeeded()) {
+ nodes.remove(n);
+ trackEdges(n, nodes);
+ }
+ }
+ // set push/pull attributes to the remaining edges
+ for (Edge e : graph.getEdges()) {
+ if (((DataFlowEdge) e).getAttribute() == null) {
+ PushPullAttribute ppat = new PushPullAttribute();
+ ppat.addOption(PushPullValue.PUSHorPULL);
+ ppat.addOption(PushPullValue.PUSH);
+ ppat.addOption(PushPullValue.PULL);
+ ((DataFlowEdge) e).setAttribute(ppat);
+ }
+ }
+ return graph;
+ }
+
+ static private void trackEdges(Node n, List nodes) {
+ // recursively set push only attributes to input side edges
+ for (Edge e : ((ResourceNode) n).getInEdges()) {
+ PushPullAttribute ppat = new PushPullAttribute();
+ ppat.addOption(PushPullValue.PUSH);
+ ((DataFlowEdge) e).setAttribute(ppat);
+ Node n2 = e.getSource();
+ if (nodes.contains(n2)) {
+ nodes.remove(n2);
+ trackEdges(n2, nodes);
+ }
+ }
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/algorithms/TypeInference.java b/AlgebraicDataflowArchitectureModel/src/algorithms/TypeInference.java
new file mode 100644
index 0000000..9b3ca65
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/algorithms/TypeInference.java
@@ -0,0 +1,2076 @@
+package algorithms;
+
+import java.util.AbstractMap;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import javax.xml.crypto.Data;
+
+import models.Node;
+import models.algebra.Constant;
+import models.algebra.Expression;
+import models.algebra.Position;
+import models.algebra.Symbol;
+import models.algebra.Term;
+import models.algebra.Type;
+import models.algebra.Variable;
+import models.dataConstraintModel.Channel;
+import models.dataConstraintModel.ChannelMember;
+import models.dataConstraintModel.DataConstraintModel;
+import models.dataConstraintModel.JsonType;
+import models.dataConstraintModel.ResourcePath;
+import models.dataConstraintModel.StateTransition;
+import models.dataFlowModel.DataTransferModel;
+import models.dataFlowModel.ResourceNode;
+
+/**
+ * Type inference for data transfer model
+ *
+ * @author Nitta
+ *
+ */
+public class TypeInference {
+ static private Map listTypes = new HashMap<>();
+ static private Map listComponentTypes = new HashMap<>();
+ static private Map, Type> tupleTypes = new HashMap<>();
+ static private Map> tupleComponentTypes = new HashMap<>();
+ static private Map pairTypes = new HashMap<>();
+ static private Map pairComponentTypes = new HashMap<>();
+ static private Map, Type> mapTypes = new HashMap<>();
+ static private Map> mapComponentTypes = new HashMap<>();
+ static private Map, Type> jsonTypes = new HashMap<>();
+ static private Map> jsonMemberTypes = new HashMap<>();
+
+ public static Type getListType(Type compType) {
+ return listTypes.get(compType);
+ }
+
+ public static Type getListComponentType(Type listType) {
+ return listComponentTypes.get(listType);
+ }
+
+ public static Collection getListTypes() {
+ return listTypes.values();
+ }
+
+ public static Type getTupleType(List compTypes) {
+ return tupleTypes.get(compTypes);
+ }
+
+ public static List getTupleComponentTypes(Type tupleType) {
+ return tupleComponentTypes.get(tupleType);
+ }
+
+ public static Collection getTupleTypes() {
+ return tupleTypes.values();
+ }
+
+ public static Type getPairType(Type compType) {
+ return pairTypes.get(compType);
+ }
+
+ public static Type getPairComponentType(Type pairType) {
+ return pairComponentTypes.get(pairType);
+ }
+
+ public static Type getMapType(List compTypes) {
+ return mapTypes.get(compTypes);
+ }
+
+ public static List getMapComponentTypes(Type mapType) {
+ return mapComponentTypes.get(mapType);
+ }
+
+ public static Type getJsonType(Map memberTypes) {
+ return jsonTypes.get(memberTypes);
+ }
+
+ public static Map getJsonMemberTypes(Type jsonType) {
+ return jsonMemberTypes.get(jsonType);
+ }
+
+ static public void infer(DataTransferModel model) {
+ Map> resources = new HashMap<>();
+ Map variables = new HashMap<>();
+ Map, Type>>> messages = new HashMap<>();
+ Map consOrSet = new HashMap<>();
+ Map tuple = new HashMap<>();
+ Map pair = new HashMap<>();
+ Map map = new HashMap<>();
+ Map json = new HashMap<>();
+
+ // Maps from the objectId of each expression to its belonging group that has the same type as the expression
+ Map> expToResource = new HashMap<>();
+ Map> expToVariable = new HashMap<>();
+ Map> expToMessage = new HashMap<>();
+ Map>> expToConsOrSet = new HashMap<>();
+ Map>> expToTuple = new HashMap<>();
+ Map>> expToPair = new HashMap<>();
+ Map>> expToMap = new HashMap<>();
+ Map>> expToJson = new HashMap<>();
+
+ // Maps from the objectId of each group to the set of updated expressions.
+ Map> updateFromResource = new HashMap<>();
+ Map> updateFromVariable = new HashMap<>();
+ Map> updateFromMessage = new HashMap<>();
+ Map> updateFromConsOrSet = new HashMap<>();
+ Map> updateFromTuple = new HashMap<>();
+ Map> updateFromPair = new HashMap<>();
+ Map> updateFromMap = new HashMap<>();
+ Map> updateFromJson = new HashMap<>();
+
+ listComponentTypes.put(DataConstraintModel.typeList, null);
+ listComponentTypes.put(DataConstraintModel.typeListInt, DataConstraintModel.typeInt);
+ listComponentTypes.put(DataConstraintModel.typeListStr, DataConstraintModel.typeString);
+ listTypes.put(DataConstraintModel.typeInt, DataConstraintModel.typeListInt);
+ listTypes.put(DataConstraintModel.typeString, DataConstraintModel.typeListStr);
+ pairComponentTypes.put(DataConstraintModel.typePair, null);
+ pairComponentTypes.put(DataConstraintModel.typePairInt, DataConstraintModel.typeInt);
+ pairComponentTypes.put(DataConstraintModel.typePairStr, DataConstraintModel.typeString);
+ pairComponentTypes.put(DataConstraintModel.typePairDouble, DataConstraintModel.typeDouble);
+ pairTypes.put(DataConstraintModel.typeInt, DataConstraintModel.typePairInt);
+ pairTypes.put(DataConstraintModel.typeString, DataConstraintModel.typePairStr);
+ pairTypes.put(DataConstraintModel.typeDouble, DataConstraintModel.typePairDouble);
+ tupleComponentTypes.put(DataConstraintModel.typeTuple, Arrays.asList(new Type[] { null, null }));
+ mapComponentTypes.put(DataConstraintModel.typeMap, Arrays.asList(new Type[] { null, null }));
+
+ // 1. Collect type information from the architecture model.
+ Collection channels = new HashSet<>(model.getIOChannels());
+ channels.addAll(model.getChannels());
+ for (Channel c : channels) {
+ for (ChannelMember cm : c.getChannelMembers()) {
+ StateTransition st = cm.getStateTransition();
+ ResourcePath res = cm.getResource();
+
+ // 1.1 Group expressions by resources.
+ List sameResource = resources.get(res);
+ if (sameResource == null) {
+ sameResource = new ArrayList<>();
+ resources.put(res, sameResource);
+ }
+ sameResource.add(st.getCurStateExpression());
+ if (st.getNextStateExpression() != null) sameResource.add(st.getNextStateExpression());
+ expToResource.put(System.identityHashCode(st.getCurStateExpression()), sameResource);
+ if (st.getNextStateExpression() != null) expToResource.put(System.identityHashCode(st.getNextStateExpression()), sameResource);
+ Map updatedExps = getUpdateSet(updateFromResource, sameResource);
+ Type resType = res.getResourceStateType();
+ Expression exp = st.getCurStateExpression();
+ Type expType = getExpTypeIfUpdatable(resType, exp);
+ if (expType != null) {
+ res.setResourceStateType(expType);
+ for (Expression resExp : sameResource) {
+ if (resExp != exp) {
+ if (resExp instanceof Variable && compareTypes(((Variable) resExp).getType(), expType)) {
+ ((Variable) resExp).setType(expType);
+ updatedExps.put(System.identityHashCode(resExp), resExp);
+ } else if (resExp instanceof Term && compareTypes(((Term) resExp).getType(), expType)) {
+ ((Term) resExp).setType(expType);
+ updatedExps.put(System.identityHashCode(resExp), resExp);
+ }
+ }
+ }
+ } else if (exp instanceof Variable) {
+ if (compareTypes(((Variable) exp).getType(), resType)) {
+ ((Variable) exp).setType(resType);
+ updatedExps.put(System.identityHashCode(exp), exp);
+ }
+ } else if (exp instanceof Term) {
+ if (compareTypes(((Term) exp).getType(), resType)) {
+ ((Term) exp).setType(resType);
+ updatedExps.put(System.identityHashCode(exp), exp);
+ }
+ }
+ resType = res.getResourceStateType();
+ exp = st.getNextStateExpression();
+ if (exp != null) {
+ expType = getExpTypeIfUpdatable(resType, exp);
+ if (expType != null) {
+ res.setResourceStateType(expType);
+ for (Expression resExp : sameResource) {
+ if (resExp != exp) {
+ if (resExp instanceof Variable && compareTypes(((Variable) resExp).getType(), expType)) {
+ ((Variable) resExp).setType(expType);
+ updatedExps.put(System.identityHashCode(resExp), resExp);
+ } else if (resExp instanceof Term && compareTypes(((Term) resExp).getType(), expType)) {
+ ((Term) resExp).setType(expType);
+ updatedExps.put(System.identityHashCode(resExp), resExp);
+ }
+ }
+ }
+ } else if (exp instanceof Variable) {
+ if (compareTypes(((Variable) exp).getType(), resType)) {
+ ((Variable) exp).setType(resType);
+ updatedExps.put(System.identityHashCode(exp), exp);
+ }
+ } else if (exp instanceof Term) {
+ if (compareTypes(((Term) exp).getType(), resType)) {
+ ((Term) exp).setType(resType);
+ updatedExps.put(System.identityHashCode(exp), exp);
+ }
+ }
+ }
+
+ // 1.2 Group expressions by variable.
+ Map> locals = new HashMap<>();
+ Map localTypes = new HashMap<>();
+ List allVariables = new ArrayList<>();
+ allVariables.addAll(st.getCurStateExpression().getVariables().values());
+ allVariables.addAll(st.getMessageExpression().getVariables().values());
+ if (st.getNextStateExpression() != null)
+ allVariables.addAll(st.getNextStateExpression().getVariables().values());
+ for (Variable var : allVariables) {
+ List sameVariable = locals.get(var.getName());
+ if (sameVariable == null) {
+ sameVariable = new ArrayList<>();
+ sameVariable.add(var);
+ expToVariable.put(System.identityHashCode(var), sameVariable);
+ locals.put(var.getName(), sameVariable);
+ localTypes.put(var.getName(), var.getType());
+ } else {
+ sameVariable.add(var);
+ expToVariable.put(System.identityHashCode(var), sameVariable);
+ Type varType = localTypes.get(var.getName());
+ Map updatedVars = getUpdateSet(updateFromVariable, sameVariable);
+ if (compareTypes(varType, var.getType())) {
+ localTypes.put(var.getName(), var.getType());
+ for (Expression v : sameVariable) {
+ if (v != var) {
+ if (compareTypes(((Variable) v).getType(), var.getType())) {
+ ((Variable) v).setType(var.getType());
+ updatedVars.put(System.identityHashCode(v), v);
+ }
+ }
+ }
+ } else if (compareTypes(var.getType(), varType)) {
+ var.setType(varType);
+ updatedVars.put(System.identityHashCode(var), var);
+ }
+ }
+ }
+ for (String varName : locals.keySet()) {
+ variables.put(System.identityHashCode(locals.get(varName)), localTypes.get(varName));
+ }
+
+ // 1.3 Group expressions by message.
+ Expression message = st.getMessageExpression();
+ if (message instanceof Variable) {
+ Type msgType = ((Variable) message).getType();
+ Map, Type>> msgTypeMap = messages.get(c);
+ if (msgTypeMap == null) {
+ msgTypeMap = new HashMap<>();
+ messages.put(c, msgTypeMap);
+ }
+ Map.Entry, Type> typeAndExps = msgTypeMap.get(0);
+ if (typeAndExps == null) {
+ List exps = new ArrayList<>();
+ exps.add(message);
+ typeAndExps = new AbstractMap.SimpleEntry<>(exps, msgType);
+ msgTypeMap.put(0, typeAndExps);
+ expToMessage.put(System.identityHashCode(message), exps);
+ } else {
+ typeAndExps.getKey().add(message);
+ expToMessage.put(System.identityHashCode(message), typeAndExps.getKey());
+ Map updateExps = getUpdateSet(updateFromMessage, typeAndExps.getKey());
+ if (compareTypes(typeAndExps.getValue(), msgType)) {
+ typeAndExps.setValue(msgType);
+ for (Expression e : typeAndExps.getKey()) {
+ if (e != message) {
+ if (e instanceof Variable) {
+ ((Variable) e).setType(msgType);
+ updateExps.put(System.identityHashCode(e), e);
+ }
+ }
+ }
+ } else if (compareTypes(msgType, typeAndExps.getValue())) {
+ ((Variable) message).setType(typeAndExps.getValue());
+ updateExps.put(System.identityHashCode(message), message);
+ }
+ }
+ } else if (message instanceof Term) {
+ Map, Type>> msgTypeMap = messages.get(c);
+ if (msgTypeMap == null) {
+ msgTypeMap = new HashMap<>();
+ messages.put(c, msgTypeMap);
+ }
+ for (int i = 0; i < ((Term) message).getArity(); i++) {
+ Expression arg = ((Term) message).getChild(i);
+ Type argType = null;
+ if (arg instanceof Variable) {
+ argType = ((Variable) arg).getType();
+ } else if (arg instanceof Term) {
+ argType = ((Term) arg).getType();
+ } else {
+ continue;
+ }
+ Map.Entry, Type> typeAndExps = msgTypeMap.get(i);
+ if (typeAndExps == null) {
+ List exps = new ArrayList<>();
+ exps.add(arg);
+ typeAndExps = new AbstractMap.SimpleEntry<>(exps, argType);
+ msgTypeMap.put(i, typeAndExps);
+ expToMessage.put(System.identityHashCode(arg), exps);
+ } else {
+ typeAndExps.getKey().add(arg);
+ expToMessage.put(System.identityHashCode(arg), typeAndExps.getKey());
+ Map updateExps = getUpdateSet(updateFromMessage, typeAndExps.getKey());
+ if (compareTypes(typeAndExps.getValue(), argType)) {
+ typeAndExps.setValue(argType);
+ for (Expression e : typeAndExps.getKey()) {
+ if (e != arg) {
+ if (e instanceof Variable) {
+ ((Variable) e).setType(argType);
+ updateExps.put(System.identityHashCode(e), e);
+ }
+ }
+ }
+ } else if (compareTypes(argType, typeAndExps.getValue())) {
+ if (arg instanceof Variable) {
+ ((Variable) arg).setType(typeAndExps.getValue());
+ updateExps.put(System.identityHashCode(arg), arg);
+ } else if (arg instanceof Term) {
+ ((Term) arg).setType(typeAndExps.getValue());
+ updateExps.put(System.identityHashCode(arg), arg);
+ }
+ }
+ }
+ }
+ }
+
+ // 1.4 Extract constraints on expressions in each term.
+ List terms = new ArrayList<>();
+ if (st.getCurStateExpression() instanceof Term) {
+ Map subTerms = ((Term) st.getCurStateExpression()).getSubTerms(Term.class);
+ terms.addAll(subTerms.values());
+ }
+ if (st.getMessageExpression() instanceof Term) {
+ Map subTerms = ((Term) st.getMessageExpression()).getSubTerms(Term.class);
+ terms.addAll(subTerms.values());
+ }
+ if (st.getNextStateExpression() != null && st.getNextStateExpression() instanceof Term) {
+ Map subTerms = ((Term) st.getNextStateExpression()).getSubTerms(Term.class);
+ terms.addAll(subTerms.values());
+ }
+ for (Term t : terms) {
+ Symbol symbol = t.getSymbol();
+ if (symbol.equals(DataConstraintModel.cons) || symbol.equals(DataConstraintModel.set)) {
+ // If the root symbol of the term is cons or set.
+ List consExps = new ArrayList<>();
+ consExps.add(t); // list term
+ updateExpressionBelonging(expToConsOrSet, t, consExps);
+ if (symbol.equals(DataConstraintModel.cons)) {
+ // If the root symbol of the term is cons.
+ for (Expression e : t.getChildren()) {
+ consExps.add(e);
+ updateExpressionBelonging(expToConsOrSet, e, consExps);
+ }
+ } else {
+ // If the root symbol of the term is set.
+ Expression e = t.getChildren().get(2);
+ consExps.add(e); // list component
+ updateExpressionBelonging(expToConsOrSet, e, consExps);
+ e = t.getChildren().get(0);
+ consExps.add(e); // list argument
+ updateExpressionBelonging(expToConsOrSet, e, consExps);
+ }
+ Type newType = getExpTypeIfUpdatable(t.getType(), consExps.get(2));
+ if (newType != null) {
+ // If the type of the 2nd argument of cons (1st argument of set) is more concrete than the type of the term.
+ t.setType(newType);
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(t), t);
+ } else {
+ Type arg2Type = null;
+ if (consExps.get(2) != null && consExps.get(2) instanceof Variable) {
+ arg2Type = ((Variable) consExps.get(2)).getType();
+ if (compareTypes(arg2Type, t.getType())) {
+ // If the type of the term is more concrete than the type of the 2nd argument of cons (1st argument of set).
+ ((Variable) consExps.get(2)).setType(t.getType());
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(consExps.get(2)), consExps.get(2));
+ }
+ } else if (consExps.get(2) != null && consExps.get(2) instanceof Term) {
+ arg2Type = ((Term) consExps.get(2)).getType();
+ if (compareTypes(arg2Type, t.getType())) {
+ // If the type of the term is more concrete than the type of the 2nd argument of cons (1st argument of set).
+ ((Term) consExps.get(2)).setType(t.getType());
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(consExps.get(2)), consExps.get(2));
+ }
+ }
+ }
+ Type newCompType = getExpTypeIfUpdatable(listComponentTypes.get(t.getType()), consExps.get(1));
+ if (newCompType != null) {
+ // If the type of the 1st argument of cons (3rd argument of set) is more concrete than the type of list component.
+ Type newListType = listTypes.get(newCompType);
+ if (newListType == null) {
+ // Create new list type.
+ newListType = createNewListType(newCompType, DataConstraintModel.typeList);
+ }
+ t.setType(newListType);
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(t), t);
+ if (consExps.get(2) != null && consExps.get(2) instanceof Variable) {
+ ((Variable) consExps.get(2)).setType(newListType);
+ updateCons.put(System.identityHashCode(consExps.get(2)), consExps.get(2));
+ } else if (consExps.get(2) != null && consExps.get(2) instanceof Term) {
+ ((Term) consExps.get(2)).setType(newListType);
+ updateCons.put(System.identityHashCode(consExps.get(2)), consExps.get(2));
+ }
+ }
+ consOrSet.put(System.identityHashCode(consExps), t.getType());
+ } else if (symbol.equals(DataConstraintModel.head) || symbol.equals(DataConstraintModel.get)) {
+ // If the root symbol of the term is head or get.
+ List consExps = new ArrayList<>();
+ Expression e = t.getChildren().get(0);
+ consExps.add(e); // list argument
+ updateExpressionBelonging(expToConsOrSet, e, consExps);
+ consExps.add(t); // list's component
+ updateExpressionBelonging(expToConsOrSet, t, consExps);
+ consExps.add(null);
+ Type listType = listTypes.get(t.getType());
+ if (listType == null && t.getType() != null) {
+ // Create a new list type.
+ listType = createNewListType(t.getType(), DataConstraintModel.typeList);
+ }
+ Type newListType = getExpTypeIfUpdatable(listType, consExps.get(0));
+ if (newListType != null) {
+ // If the type of the component of the 1st argument is more concrete than the type of the term.
+ Type newCompType = listComponentTypes.get(newListType);
+ if (newCompType != null) {
+ t.setType(newCompType);
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(t), t);
+ }
+ consOrSet.put(System.identityHashCode(consExps), newListType);
+ } else {
+ // If the type of the term is more concrete than the type of the component of the 1st argument.
+ if (consExps.get(0) != null && consExps.get(0) instanceof Variable) {
+ ((Variable) consExps.get(0)).setType(listType);
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(consExps.get(0)), consExps.get(0));
+ } else if (consExps.get(0) != null && consExps.get(0) instanceof Term) {
+ ((Term) consExps.get(0)).setType(listType);
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(consExps.get(0)), consExps.get(0));
+ }
+ consOrSet.put(System.identityHashCode(consExps), listType);
+ }
+ } else if (symbol.equals(DataConstraintModel.tail)) {
+ // If the root symbol of the term is tail.
+ List consExps = new ArrayList<>();
+ consExps.add(t); // list term
+ updateExpressionBelonging(expToConsOrSet, t, consExps);
+ consExps.add(null); // list's component
+ Expression e = t.getChildren().get(0);
+ consExps.add(e); // list argument
+ updateExpressionBelonging(expToConsOrSet, e, consExps);
+ Type newType = getExpTypeIfUpdatable(t.getType(), consExps.get(2));
+ if (newType != null) {
+ // If the type of the argument is more concrete than the type of the term.
+ t.setType(newType);
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(t), t);
+ } else {
+ Type argType = null;
+ if (consExps.get(2) != null && consExps.get(2) instanceof Variable) {
+ argType = ((Variable) consExps.get(2)).getType();
+ if (compareTypes(argType, t.getType())) {
+ // If the type of the term is more concrete than the type of the argument.
+ ((Variable) consExps.get(2)).setType(t.getType());
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(consExps.get(2)), consExps.get(2));
+ }
+ } else if (consExps.get(2) != null && consExps.get(2) instanceof Term) {
+ argType = ((Term) consExps.get(2)).getType();
+ if (compareTypes(argType, t.getType())) {
+ // If the type of the term is more concrete than the type of the argument.
+ ((Term) consExps.get(2)).setType(t.getType());
+ Map updateCons = getUpdateSet(updateFromConsOrSet, consExps);
+ updateCons.put(System.identityHashCode(consExps.get(2)), consExps.get(2));
+ }
+ }
+ }
+ consOrSet.put(System.identityHashCode(consExps), t.getType());
+ } else if (symbol.equals(DataConstraintModel.tuple)) {
+ // If the root symbol of the term is tuple.
+ List tupleExps = new ArrayList<>();
+ List newArgTypesList = new ArrayList<>();
+ tupleExps.add(t); // tuple term
+ updateExpressionBelonging(expToTuple, t, tupleExps);
+ for (Expression e : t.getChildren()) {
+ tupleExps.add(e); // tuple's component
+ updateExpressionBelonging(expToTuple, e, tupleExps);
+ if (e instanceof Variable) {
+ newArgTypesList.add(((Variable) e).getType());
+ } else if (e instanceof Term) {
+ newArgTypesList.add(((Term) e).getType());
+ } else {
+ newArgTypesList.add(null);
+ }
+ }
+ if (t.getType() == DataConstraintModel.typeTuple) {
+ Type newTupleType = tupleTypes.get(newArgTypesList);
+ if (newTupleType == null) {
+ // Create new tuple type;
+ newTupleType = createNewTupleType(newArgTypesList, DataConstraintModel.typeTuple);
+ }
+ // Update the type of the tuple term and record the updated expression.
+ t.setType(newTupleType);
+ Map updateExps = getUpdateSet(updateFromTuple, tupleExps);
+ updateExps.put(System.identityHashCode(t), t);
+ }
+ tuple.put(System.identityHashCode(tupleExps), t.getType());
+ } else if (symbol.equals(DataConstraintModel.pair)) {
+ // If the root symbol of the term is pair.
+ List pairExps = new ArrayList<>();
+ pairExps.add(t); // pair
+ updateExpressionBelonging(expToPair, t, pairExps);
+ if (t.getType() == DataConstraintModel.typePair) {
+ for (Expression e : t.getChildren()) {
+ pairExps.add(e); // left/right
+ updateExpressionBelonging(expToPair, e, pairExps);
+ Type newArgType = null;
+ if (e instanceof Variable) {
+ newArgType = (((Variable) e).getType());
+
+ } else if (e instanceof Term) {
+ newArgType = (((Term) e).getType());
+ }
+
+ if (newArgType != null) {
+ Type newPairType = pairTypes.get(newArgType);
+ if (newPairType != null) {
+ t.setType(newPairType);
+ Map updateExps = getUpdateSet(updateFromPair, pairExps);
+ updateExps.put(System.identityHashCode(t), t);
+ }
+ }
+ }
+ pair.put(System.identityHashCode(pairExps), t.getType());
+
+ }
+ } else if (symbol.equals(DataConstraintModel.fst)) {
+ // If the root symbol of the term is fst.
+ List tupleExps = new ArrayList<>();
+ Expression arg = t.getChildren().get(0);
+ tupleExps.add(arg); // tuple argument
+ updateExpressionBelonging(expToTuple, arg, tupleExps);
+ tupleExps.add(t); // first component
+ updateExpressionBelonging(expToTuple, t, tupleExps);
+ tupleExps.add(null); // second component
+ Type argType = null;
+ if (arg instanceof Variable) {
+ argType = ((Variable) arg).getType();
+ } else if (arg instanceof Term) {
+ argType = ((Term) arg).getType();
+ }
+ Type newTupleType = DataConstraintModel.typeTuple;
+ if (argType == DataConstraintModel.typeTuple && t.getType() != null) {
+ List newCompTypeList = new ArrayList<>();
+ newCompTypeList.add(t.getType());
+ newCompTypeList.add(null);
+ newTupleType = tupleTypes.get(newCompTypeList);
+ if (newTupleType == null) {
+ // Create new tuple type;
+ newTupleType = createNewTupleType(newCompTypeList, DataConstraintModel.typeTuple);
+ }
+ }
+ if (argType != newTupleType && newTupleType != null) {
+ // Update the type of the tuple argument and record the updated expression.
+ if (arg instanceof Variable) {
+ ((Variable) arg).setType(newTupleType);
+ argType = newTupleType;
+ } else if (arg instanceof Term) {
+ ((Term) arg).setType(newTupleType);
+ argType = newTupleType;
+ }
+ Map updateExps = getUpdateSet(updateFromTuple, tupleExps);
+ updateExps.put(System.identityHashCode(arg), arg);
+ }
+ tuple.put(System.identityHashCode(tupleExps), argType);
+ } else if (symbol.equals(DataConstraintModel.snd)) {
+ // If the root symbol of the term is snd.
+ List tupleExps = new ArrayList<>();
+ Expression arg = t.getChildren().get(0);
+ tupleExps.add(arg); // tuple argument
+ updateExpressionBelonging(expToTuple, arg, tupleExps);
+ tupleExps.add(null); // first component
+ tupleExps.add(t); // second component
+ updateExpressionBelonging(expToTuple, t, tupleExps);
+ Type argType = null;
+ if (arg instanceof Variable) {
+ argType = ((Variable) arg).getType();
+ } else if (arg instanceof Term) {
+ argType = ((Term) arg).getType();
+ }
+ Type newTupleType = DataConstraintModel.typeTuple;
+ if (argType == DataConstraintModel.typeTuple && t.getType() != null) {
+ List newCompTypeList = new ArrayList<>();
+ newCompTypeList.add(null);
+ if (DataConstraintModel.typeTuple.isAncestorOf(t.getType())) {
+ List sndTypes = tupleComponentTypes.get(t.getType());
+ if (sndTypes != null) {
+ for (Type t2: sndTypes) {
+ newCompTypeList.add(t2);
+ }
+ } else {
+ newCompTypeList.add(t.getType());
+ }
+ } else {
+ newCompTypeList.add(t.getType());
+ }
+ newTupleType = tupleTypes.get(newCompTypeList);
+ if (newTupleType == null) {
+ // Create new tuple type;
+ newTupleType = createNewTupleType(newCompTypeList, DataConstraintModel.typeTuple);
+ }
+ }
+ if (argType != newTupleType && newTupleType != null) {
+ // Update the type of the tuple argument and record the updated expression.
+ if (arg instanceof Variable) {
+ ((Variable) arg).setType(newTupleType);
+ argType = newTupleType;
+ } else if (arg instanceof Term) {
+ ((Term) arg).setType(newTupleType);
+ argType = newTupleType;
+ }
+ Map updateExps = getUpdateSet(updateFromTuple, tupleExps);
+ updateExps.put(System.identityHashCode(arg), arg);
+ }
+ tuple.put(System.identityHashCode(tupleExps), argType);
+ } else if (symbol.equals(DataConstraintModel.left)) {
+ // If the root symbol of the term is left.
+ List pairExps = new ArrayList<>();
+ Expression arg = t.getChildren().get(0);
+ pairExps.add(arg); // pair
+ updateExpressionBelonging(expToPair, arg, pairExps);
+ pairExps.add(t); // left
+ updateExpressionBelonging(expToPair, t, pairExps);
+ pairExps.add(null); // right
+ Type argType = null;
+ if (arg instanceof Variable) {
+ argType = ((Variable) arg).getType();
+ } else if (arg instanceof Term) {
+ argType = ((Term) arg).getType();
+ }
+ Type newPairType = DataConstraintModel.typePair;
+ if (argType == DataConstraintModel.typePair && t.getType() != null) {
+ List newCompTypeList = new ArrayList<>();
+ newCompTypeList.add(t.getType());
+ newCompTypeList.add(null);
+ newPairType = pairTypes.get(newCompTypeList);
+ if (newPairType == null) {
+ // Create new tuple type;
+ newPairType = createNewTupleType(newCompTypeList, DataConstraintModel.typePair);
+ }
+ }
+ if (argType != newPairType && newPairType != null) {
+ if (arg instanceof Variable) {
+ ((Variable) arg).setType(newPairType);
+ argType = newPairType;
+ } else if (arg instanceof Term) {
+ ((Term) arg).setType(newPairType);
+ argType = newPairType;
+ }
+ Map updateExps = getUpdateSet(updateFromPair, pairExps);
+ updateExps.put(System.identityHashCode(arg), arg);
+ }
+ pair.put(System.identityHashCode(pairExps), argType);
+ } else if (symbol.equals(DataConstraintModel.right)) {
+ // If the root symbol of the term is right.
+ List pairExps = new ArrayList<>();
+ Expression arg = t.getChildren().get(0);
+ pairExps.add(arg); // pair
+ updateExpressionBelonging(expToPair, arg, pairExps);
+ pairExps.add(null); // left
+ pairExps.add(t); // right
+ updateExpressionBelonging(expToPair, t, pairExps);
+ Type argType = null;
+ if (arg instanceof Variable) {
+ argType = ((Variable) arg).getType();
+ } else if (arg instanceof Term) {
+ argType = ((Term) arg).getType();
+ }
+ Type newPairType = DataConstraintModel.typePair;
+ if (argType == DataConstraintModel.typePair && t.getType() != null) {
+ List newCompTypeList = new ArrayList<>();
+ newCompTypeList.add(null);
+ newCompTypeList.add(t.getType());
+ newPairType = pairTypes.get(newCompTypeList);
+ if (newPairType == null) {
+ // Create new tuple type;
+ newPairType = createNewTupleType(newCompTypeList, DataConstraintModel.typePair);
+ }
+ }
+ if (argType != newPairType && newPairType != null) {
+ if (arg instanceof Variable) {
+ ((Variable) arg).setType(newPairType);
+ argType = newPairType;
+ } else if (arg instanceof Term) {
+ ((Term) arg).setType(newPairType);
+ argType = newPairType;
+ }
+ Map updateExps = getUpdateSet(updateFromPair, pairExps);
+ updateExps.put(System.identityHashCode(arg), arg);
+ }
+ pair.put(System.identityHashCode(pairExps), argType);
+ } else if (symbol.equals(DataConstraintModel.lookup)) {
+ // If the root symbol of the term is lookup.
+ List mapExps = new ArrayList<>();
+ Expression arg1 = t.getChildren().get(0); // map
+ mapExps.add(arg1);
+ updateExpressionBelonging(expToMap, arg1, mapExps);
+ Expression arg2 = t.getChildren().get(1); // key
+ mapExps.add(arg2);
+ updateExpressionBelonging(expToMap, arg2, mapExps);
+ mapExps.add(t); // value
+ updateExpressionBelonging(expToMap, t, mapExps);
+ Type arg1Type = null;
+ if (arg1 instanceof Variable) {
+ arg1Type = ((Variable) arg1).getType();
+ } else if (arg1 instanceof Term) {
+ arg1Type = ((Term) arg1).getType();
+ }
+ List newCompTypeList = new ArrayList<>();
+ if (arg2 instanceof Variable) {
+ newCompTypeList.add(((Variable) arg2).getType());
+ } else if (arg2 instanceof Term) {
+ newCompTypeList.add(((Term) arg2).getType());
+ } else {
+ newCompTypeList.add(null);
+ }
+ newCompTypeList.add(t.getType());
+ if (arg1Type == DataConstraintModel.typeMap || arg1Type == null) {
+ Type newMapType = mapTypes.get(newCompTypeList);
+ if (newMapType == null) {
+ // Create new tuple type;
+ newMapType = createNewMapType(newCompTypeList, DataConstraintModel.typeMap);
+ }
+ // Update the type of the map argument and record the updated expression.
+ if (arg1 instanceof Variable) {
+ ((Variable) arg1).setType(newMapType);
+ arg1Type = newMapType;
+ } else if (arg1 instanceof Term) {
+ ((Term) arg1).setType(newMapType);
+ arg1Type = newMapType;
+ }
+ Map updateExps = getUpdateSet(updateFromMap, mapExps);
+ updateExps.put(System.identityHashCode(arg1), arg1);
+ }
+ map.put(System.identityHashCode(mapExps), arg1Type);
+ } else if (symbol.equals(DataConstraintModel.insert)) {
+ // If the root symbol of the term is insert.
+ List mapExps = new ArrayList<>();
+ mapExps.add(t); // map
+ updateExpressionBelonging(expToMap, t, mapExps);
+ Expression arg1 = t.getChildren().get(1); // key
+ mapExps.add(arg1);
+ updateExpressionBelonging(expToMap, arg1, mapExps);
+ Expression arg2 = t.getChildren().get(2); // value
+ mapExps.add(arg2);
+ updateExpressionBelonging(expToMap, arg2, mapExps);
+ Expression arg0 = t.getChildren().get(0); // map
+ mapExps.add(arg0);
+ updateExpressionBelonging(expToMap, arg0, mapExps);
+ Type termType = t.getType();
+ List newCompTypeList = new ArrayList<>();
+ if (arg1 instanceof Variable) {
+ newCompTypeList.add(((Variable) arg1).getType());
+ } else if (arg1 instanceof Term) {
+ newCompTypeList.add(((Term) arg1).getType());
+ } else {
+ newCompTypeList.add(null);
+ }
+ if (arg2 instanceof Variable) {
+ newCompTypeList.add(((Variable) arg2).getType());
+ } else if (arg2 instanceof Term) {
+ newCompTypeList.add(((Term) arg2).getType());
+ } else {
+ newCompTypeList.add(null);
+ }
+ if (termType == DataConstraintModel.typeMap || termType == null) {
+ Type newMapType = mapTypes.get(newCompTypeList);
+ if (newMapType == null) {
+ // Create new tuple type;
+ newMapType = createNewMapType(newCompTypeList, DataConstraintModel.typeMap);
+ }
+ // Update the type of the map term and record the updated expression.
+ t.setType(newMapType);
+ termType = newMapType;
+ Map updateExps = getUpdateSet(updateFromMap, mapExps);
+ updateExps.put(System.identityHashCode(t), t);
+ }
+ map.put(System.identityHashCode(mapExps), termType);
+ } else if (symbol.equals(DataConstraintModel.addMember)) {
+ // If the root symbol of the term is addMember (addMember(json, key, value)).
+ List dotExps = new ArrayList<>();
+ Expression jsonArg = t.getChildren().get(0);
+ Expression keyArg = t.getChildren().get(1);
+ Expression valueArg = t.getChildren().get(2);
+ dotExps.add(t); // json
+ updateExpressionBelonging(expToJson, t, dotExps);
+ dotExps.add(keyArg); // key
+ updateExpressionBelonging(expToJson, keyArg, dotExps);
+ dotExps.add(valueArg); // value
+ updateExpressionBelonging(expToJson, valueArg, dotExps);
+ dotExps.add(jsonArg); // json
+ updateExpressionBelonging(expToJson, jsonArg, dotExps);
+ Type jsonType = t.getType();
+ Type valueType = null;
+ if (valueArg instanceof Variable) {
+ valueType = ((Variable) valueArg).getType();
+ } else if (valueArg instanceof Term) {
+ valueType = ((Term) valueArg).getType();
+ }
+ String keyName = null;
+ if (keyArg instanceof Constant) {
+ keyName = ((Constant) keyArg).getSymbol().getName();
+ }
+ Type jsonArgType = null;
+ if (jsonArg instanceof Variable) {
+ jsonArgType = ((Variable) jsonArg).getType();
+ } else if (jsonArg instanceof Term) {
+ jsonArgType = ((Term) jsonArg).getType();
+ }
+ Type newJsonType = DataConstraintModel.typeJson;
+ if (jsonType == DataConstraintModel.typeJson && jsonArgType != null && keyName != null) {
+ Map newMemberTypes = new HashMap<>(((JsonType) jsonArgType).getMemberTypes());
+ newMemberTypes.put(keyName, valueType);
+ newJsonType = jsonTypes.get(newMemberTypes);
+ if (newJsonType == null) {
+ // Create new json type;
+ newJsonType = createNewJsonType(newMemberTypes, DataConstraintModel.typeJson);
+ }
+ }
+ if (jsonType != newJsonType && newJsonType != null && !newJsonType.isAncestorOf(jsonType)) {
+ // Update the type of the json term and record the updated expression.
+ t.setType(newJsonType);
+ jsonType = newJsonType;
+ Map updateExps = getUpdateSet(updateFromJson, dotExps);
+ updateExps.put(System.identityHashCode(t), t);
+ }
+ json.put(System.identityHashCode(dotExps), jsonType);
+ } else if (symbol.equals(DataConstraintModel.dot)) {
+ // If the root symbol of the term is dot (json.property).
+ List dotExps = new ArrayList<>();
+ Expression jsonArg = t.getChildren().get(0);
+ Expression keyArg = t.getChildren().get(1);
+ dotExps.add(jsonArg); // json
+ updateExpressionBelonging(expToJson, jsonArg, dotExps);
+ dotExps.add(keyArg); // key
+ updateExpressionBelonging(expToJson, keyArg, dotExps);
+ dotExps.add(t); // value
+ updateExpressionBelonging(expToJson, t, dotExps);
+ dotExps.add(null); // json
+ Type jsonType = null;
+ if (jsonArg instanceof Variable) {
+ jsonType = ((Variable) jsonArg).getType();
+ } else if (jsonArg instanceof Term) {
+ jsonType = ((Term) jsonArg).getType();
+ }
+ String keyName = null;
+ if (keyArg instanceof Constant) {
+ keyName = ((Constant) keyArg).getSymbol().getName();
+ }
+ Type newJsonType = DataConstraintModel.typeJson;
+ if (jsonType == DataConstraintModel.typeJson && t.getType() != null && keyName != null) {
+ Map newMemberTypes = new HashMap<>();
+ newMemberTypes.put(keyName, t.getType());
+ newJsonType = jsonTypes.get(newMemberTypes);
+ if (newJsonType == null) {
+ // Create new json type;
+ newJsonType = createNewJsonType(newMemberTypes, DataConstraintModel.typeJson);
+ }
+ }
+ if (jsonType != newJsonType && newJsonType != null && !newJsonType.isAncestorOf(jsonType)) {
+ // Update the type of the json argument and record the updated expression.
+ if (jsonArg instanceof Variable) {
+ ((Variable) jsonArg).setType(newJsonType);
+ jsonType = newJsonType;
+ } else if (jsonArg instanceof Term) {
+ ((Term) jsonArg).setType(newJsonType);
+ jsonType = newJsonType;
+ }
+ Map updateExps = getUpdateSet(updateFromJson, dotExps);
+ updateExps.put(System.identityHashCode(jsonArg), jsonArg);
+ }
+ json.put(System.identityHashCode(dotExps), jsonType);
+ } else if (symbol.equals(DataConstraintModel.dotParam)) {
+ // If the root symbol of the term is dot (json.{param}).
+ List dotExps = new ArrayList<>();
+ Expression jsonArg = t.getChildren().get(0);
+ Expression keyArg = t.getChildren().get(1);
+ dotExps.add(jsonArg); // json (list/map)
+ updateExpressionBelonging(expToJson, jsonArg, dotExps);
+ dotExps.add(null); // key
+ dotExps.add(t); // value
+ updateExpressionBelonging(expToJson, t, dotExps);
+ dotExps.add(null); // json
+ Type jsonType = null;
+ if (jsonArg instanceof Variable) {
+ jsonType = ((Variable) jsonArg).getType();
+ } else if (jsonArg instanceof Term) {
+ jsonType = ((Term) jsonArg).getType();
+ }
+ Type keyType = null;
+ if (keyArg instanceof Variable) {
+ keyType = ((Variable) keyArg).getType();
+ } else if (keyArg instanceof Term) {
+ keyType = ((Term) keyArg).getType();
+ }
+ Type newJsonType = null;
+ if (keyType == DataConstraintModel.typeInt) {
+ newJsonType = DataConstraintModel.typeList;
+ } else if (keyType == DataConstraintModel.typeString) {
+ newJsonType = DataConstraintModel.typeMap;
+ }
+ if (t.getType() != null) {
+ if ((jsonType == DataConstraintModel.typeList)) {
+ newJsonType = listTypes.get(t.getType());
+ if (newJsonType == null) {
+ // Create new list type;
+ newJsonType = createNewListType(t.getType(), DataConstraintModel.typeList);
+ }
+ } else if (jsonType == DataConstraintModel.typeMap) {
+ List keyValueTypes = Arrays.asList(new Type[] {DataConstraintModel.typeString, t.getType()});
+ newJsonType = mapTypes.get(keyValueTypes);
+ if (newJsonType == null) {
+ // Create new map type;
+ newJsonType = createNewMapType(keyValueTypes, DataConstraintModel.typeMap);
+ }
+ }
+ }
+ if (jsonType != newJsonType && newJsonType != null && !newJsonType.isAncestorOf(jsonType)) {
+ // Update the type of the json argument and record the updated expression.
+ if (jsonArg instanceof Variable) {
+ ((Variable) jsonArg).setType(newJsonType);
+ jsonType = newJsonType;
+ } else if (jsonArg instanceof Term) {
+ ((Term) jsonArg).setType(newJsonType);
+ jsonType = newJsonType;
+ }
+ Map updateExps = getUpdateSet(updateFromJson, dotExps);
+ updateExps.put(System.identityHashCode(jsonArg), jsonArg);
+ }
+ json.put(System.identityHashCode(dotExps), jsonType);
+ } else if (symbol.equals(DataConstraintModel.cond)) {
+ // If the root symbol of the term is if function.
+ Expression c1 = t.getChild(1);
+ Expression c2 = t.getChild(2);
+ List condTerms = new ArrayList<>();
+ condTerms.add(t);
+ condTerms.add(c1);
+ condTerms.add(c2);
+ expToVariable.put(System.identityHashCode(t), condTerms);
+ expToVariable.put(System.identityHashCode(c1), condTerms);
+ expToVariable.put(System.identityHashCode(c2), condTerms);
+ Type condType = t.getType();
+ Map updatedVars = getUpdateSet(updateFromVariable, condTerms);
+ Type child1Type = getExpTypeIfUpdatable(condType, c1);
+ if (child1Type != null) {
+ condType = child1Type;
+ t.setType(child1Type);
+ updatedVars.put(System.identityHashCode(t), t);
+ } else {
+ if (c1 instanceof Variable && compareTypes(((Variable) c1).getType(), condType)) {
+ ((Variable) c1).setType(condType);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ } else if (c1 instanceof Term && compareTypes(((Term) c1).getType(), condType)) {
+ ((Term) c1).setType(condType);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ }
+ }
+ Type child2Type = getExpTypeIfUpdatable(condType, c2);
+ if (child2Type != null) {
+ condType = child2Type;
+ t.setType(child2Type);
+ updatedVars.put(System.identityHashCode(t), t);
+ if (c1 instanceof Variable) {
+ ((Variable) c1).setType(child2Type);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ } else if (c1 instanceof Term) {
+ ((Term) c1).setType(child2Type);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ }
+ } else {
+ if (c2 instanceof Variable && compareTypes(((Variable) c2).getType(), condType)) {
+ ((Variable) c2).setType(condType);
+ updatedVars.put(System.identityHashCode(c2), c2);
+ } else if (c2 instanceof Term && compareTypes(((Term) c2).getType(), condType)) {
+ ((Term) c2).setType(condType);
+ updatedVars.put(System.identityHashCode(c2), c2);
+ }
+ }
+ variables.put(System.identityHashCode(condTerms), condType);
+ } else if (symbol.equals(DataConstraintModel.add) || symbol.equals(DataConstraintModel.sub)
+ || symbol.equals(DataConstraintModel.mul) || symbol.equals(DataConstraintModel.div)) {
+ // If the root symbol of the term is arithmetic operators.
+ Expression c1 = t.getChild(0);
+ Expression c2 = t.getChild(1);
+ List operands = new ArrayList<>();
+ operands.add(t);
+ operands.add(c1);
+ operands.add(c2);
+ expToVariable.put(System.identityHashCode(t), operands);
+ expToVariable.put(System.identityHashCode(c1), operands);
+ expToVariable.put(System.identityHashCode(c2), operands);
+ Type opType = t.getType();
+ Map updatedVars = getUpdateSet(updateFromVariable, operands);
+ Type child1Type = getExpTypeIfUpdatable(opType, c1);
+ if (child1Type != null) {
+ opType = child1Type;
+ t.setType(child1Type);
+ updatedVars.put(System.identityHashCode(t), t);
+ } else {
+ if (c1 instanceof Variable && compareTypes(((Variable) c1).getType(), opType)) {
+ ((Variable) c1).setType(opType);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ } else if (c1 instanceof Term && compareTypes(((Term) c1).getType(), opType)) {
+ ((Term) c1).setType(opType);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ }
+ }
+ Type child2Type = getExpTypeIfUpdatable(opType, c2);
+ if (child2Type != null) {
+ opType = child2Type;
+ t.setType(child2Type);
+ updatedVars.put(System.identityHashCode(t), t);
+ if (c1 instanceof Variable) {
+ ((Variable) c1).setType(child2Type);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ } else if (c1 instanceof Term) {
+ ((Term) c1).setType(child2Type);
+ updatedVars.put(System.identityHashCode(c1), c1);
+ }
+ } else {
+ if (c2 instanceof Variable && compareTypes(((Variable) c2).getType(), opType)) {
+ ((Variable) c2).setType(opType);
+ updatedVars.put(System.identityHashCode(c2), c2);
+ } else if (c2 instanceof Term && compareTypes(((Term) c2).getType(), opType)) {
+ ((Term) c2).setType(opType);
+ updatedVars.put(System.identityHashCode(c2), c2);
+ }
+ }
+ variables.put(System.identityHashCode(operands), opType);
+ } else if (symbol.getSignature() != null
+ && symbol.getSignature()[0] == DataConstraintModel.typeList) {
+ // If the root symbol of the term is the list type (except for the cons
+ // function).
+ List consExps = new ArrayList<>();
+ consExps.add(t);
+ expToVariable.put(System.identityHashCode(t), consExps);
+ Type condType = t.getType();
+ Map updatedVars = getUpdateSet(updateFromVariable, consExps);
+ for (int i = 1; i < symbol.getSignature().length; i++) {
+ Type tc = symbol.getSignature()[i];
+ if (tc == DataConstraintModel.typeList) {
+ Expression e = t.getChildren().get(i - 1);
+ Type newType = getExpTypeIfUpdatable(condType, e);
+ if (newType != null) {
+ condType = newType;
+ for (Expression e2 : consExps) {
+ if (e2 instanceof Variable) {
+ ((Variable) e2).setType(newType);
+ updatedVars.put(System.identityHashCode(e2), e2);
+ } else if (e2 instanceof Term) {
+ ((Term) e2).setType(newType);
+ updatedVars.put(System.identityHashCode(e2), e2);
+ }
+ }
+ } else {
+ if (e instanceof Variable && compareTypes(((Variable) e).getType(), condType)) {
+ ((Variable) e).setType(condType);
+ updatedVars.put(System.identityHashCode(e), e);
+ } else if (e instanceof Term && compareTypes(((Term) e).getType(), condType)) {
+ ((Term) e).setType(condType);
+ updatedVars.put(System.identityHashCode(e), e);
+ }
+ }
+ consExps.add(e);
+ expToVariable.put(System.identityHashCode(e), consExps);
+ }
+ }
+ variables.put(System.identityHashCode(consExps), condType);
+ }
+ }
+ }
+ }
+
+ // 2. Propagate type information.
+ while (updateFromResource.size() > 0 || updateFromVariable.size() > 0 || updateFromMessage.size() > 0
+ || updateFromConsOrSet.size() > 0 || updateFromTuple.size() > 0 || updateFromPair.size() > 0
+ || updateFromMap.size() > 0 || updateFromJson.size() > 0) {
+ if (updateFromResource.size() > 0) {
+ Set resourceKeys = updateFromResource.keySet();
+ Integer resourceKey = resourceKeys.iterator().next();
+ Map resourceValue = updateFromResource.get(resourceKey);
+ updateFromResource.remove(resourceKey);
+ for (int i : resourceValue.keySet()) {
+ Expression resExp = resourceValue.get(i);
+ updateVaribleTypes(resExp, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(resExp, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(resExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(resExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(resExp, pair, expToPair, updateFromPair);
+ updateMapTypes(resExp, map, expToMap, updateFromMap);
+ updateJsonTypes(resExp, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromVariable.size() > 0) {
+ Set variableKeys = updateFromVariable.keySet();
+ Integer variableKey = variableKeys.iterator().next();
+ Map variableValue = updateFromVariable.get(variableKey);
+ updateFromVariable.remove(variableKey);
+ for (int i : variableValue.keySet()) {
+ Expression var = variableValue.get(i);
+ updateResourceTypes(var, resources, expToResource, updateFromResource);
+ updateVaribleTypes(var, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(var, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(var, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(var, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(var, pair, expToPair, updateFromPair);
+ updateMapTypes(var, map, expToMap, updateFromMap);
+ updateJsonTypes(var, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromMessage.size() > 0) {
+ Set messageKeys = updateFromMessage.keySet();
+ Integer messageKey = messageKeys.iterator().next();
+ Map messageValue = updateFromMessage.get(messageKey);
+ updateFromMessage.remove(messageKey);
+ for (int i : messageValue.keySet()) {
+ Expression mesExp = messageValue.get(i);
+ updateResourceTypes(mesExp, resources, expToResource, updateFromResource);
+ updateVaribleTypes(mesExp, variables, expToVariable, updateFromVariable);
+ updateConsOrSetTypes(mesExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(mesExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(mesExp, pair, expToPair, updateFromPair);
+ updateMapTypes(mesExp, map, expToMap, updateFromMap);
+ updateJsonTypes(mesExp, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromConsOrSet.size() > 0) {
+ Set consKeys = updateFromConsOrSet.keySet();
+ Integer consKey = consKeys.iterator().next();
+ Map consValue = updateFromConsOrSet.get(consKey);
+ updateFromConsOrSet.remove(consKey);
+ for (int i : consValue.keySet()) {
+ Expression consExp = consValue.get(i);
+ updateResourceTypes(consExp, resources, expToResource, updateFromResource);
+ updateVaribleTypes(consExp, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(consExp, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(consExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(consExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(consExp, pair, expToPair, updateFromPair);
+ updateMapTypes(consExp, map, expToMap, updateFromMap);
+ updateJsonTypes(consExp, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromTuple.size() > 0) {
+ Set tupleKeys = updateFromTuple.keySet();
+ Integer tupleKey = tupleKeys.iterator().next();
+ Map tupleValue = updateFromTuple.get(tupleKey);
+ updateFromTuple.remove(tupleKey);
+ for (int i : tupleValue.keySet()) {
+ Expression tupleExp = tupleValue.get(i);
+ updateResourceTypes(tupleExp, resources, expToResource, updateFromResource);
+ updateVaribleTypes(tupleExp, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(tupleExp, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(tupleExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(tupleExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(tupleExp, pair, expToPair, updateFromPair);
+ updateMapTypes(tupleExp, map, expToMap, updateFromMap);
+ updateJsonTypes(tupleExp, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromPair.size() > 0) {
+ Set pairKeys = updateFromPair.keySet();
+ Integer pairKey = pairKeys.iterator().next();
+ Map pairValue = updateFromPair.get(pairKey);
+ updateFromPair.remove(pairKey);
+ for (int i : pairValue.keySet()) {
+ Expression pairExp = pairValue.get(i);
+ updateResourceTypes(pairExp, resources, expToResource, updateFromResource);
+ updateVaribleTypes(pairExp, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(pairExp, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(pairExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(pairExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(pairExp, pair, expToPair, updateFromPair);
+ updateMapTypes(pairExp, map, expToMap, updateFromMap);
+ updateJsonTypes(pairExp, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromMap.size() > 0) {
+ Set mapKeys = updateFromMap.keySet();
+ Integer mapKey = mapKeys.iterator().next();
+ Map mapValue = updateFromMap.get(mapKey);
+ updateFromMap.remove(mapKey);
+ for (int i : mapValue.keySet()) {
+ Expression mapExp = mapValue.get(i);
+ updateResourceTypes(mapExp, resources, expToResource, updateFromResource);
+ updateVaribleTypes(mapExp, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(mapExp, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(mapExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(mapExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(mapExp, pair, expToPair, updateFromPair);
+ updateMapTypes(mapExp, map, expToMap, updateFromMap);
+ updateJsonTypes(mapExp, json, expToJson, updateFromJson);
+ }
+ }
+ if (updateFromJson.size() > 0) {
+ Set jsonKeys = updateFromJson.keySet();
+ Integer jsonKey = jsonKeys.iterator().next();
+ Map jsonValue = updateFromJson.get(jsonKey);
+ updateFromJson.remove(jsonKey);
+ for (int i : jsonValue.keySet()) {
+ Expression jsonExp = jsonValue.get(i);
+ updateResourceTypes(jsonExp, resources, expToResource, updateFromResource);
+ updateVaribleTypes(jsonExp, variables, expToVariable, updateFromVariable);
+ updateMessageTypes(jsonExp, messages, expToMessage, updateFromMessage);
+ updateConsOrSetTypes(jsonExp, consOrSet, expToConsOrSet, updateFromConsOrSet);
+ updateTupleTypes(jsonExp, tuple, expToTuple, updateFromTuple);
+ updatePairTypes(jsonExp, pair, expToPair, updateFromPair);
+ updateMapTypes(jsonExp, map, expToMap, updateFromMap);
+ updateJsonTypes(jsonExp, json, expToJson, updateFromJson);
+ }
+ }
+ }
+ }
+
+ private static void updateExpressionBelonging(Map>> belonging, Expression exp, List group) {
+ Set> groups = belonging.get(System.identityHashCode(exp));
+ if (groups == null) {
+ groups = new HashSet<>();
+ belonging.put(System.identityHashCode(exp), groups);
+ groups.add(group);
+ return;
+ }
+ if (!groups.contains(group)) {
+ groups.add(group);
+ }
+ }
+
+ private static void updateResourceTypes(Expression exp, Map> resources,
+ Map> expToResource, Map> updateFromResource) {
+ List sameResource = expToResource.get(System.identityHashCode(exp));
+ if (sameResource == null) return;
+ for (ResourcePath res : resources.keySet()) {
+ if (resources.get(res) == sameResource) {
+ Type resType = res.getResourceStateType();
+ Type newResType = getExpTypeIfUpdatable(resType, exp);
+ if (newResType != null) {
+ res.setResourceStateType(newResType);
+ Map updateExps = getUpdateSet(updateFromResource, sameResource);
+ for (Expression resExp : sameResource) {
+ if (resExp != exp) {
+ if (resExp instanceof Variable) {
+ ((Variable) resExp).setType(newResType);
+ updateExps.put(System.identityHashCode(resExp), resExp);
+ } else if (resExp instanceof Term) {
+ ((Term) resExp).setType(newResType);
+ updateExps.put(System.identityHashCode(resExp), resExp);
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+
+ private static void updateVaribleTypes(Expression exp, Map variables,
+ Map> expToVariable, Map> updateFromVariable) {
+ List sameVariable = expToVariable.get(System.identityHashCode(exp));
+ if (sameVariable == null) return;
+ Type varType = variables.get(System.identityHashCode(sameVariable));
+ Type newVarType = getExpTypeIfUpdatable(varType, exp);
+ if (newVarType != null) {
+ variables.put(System.identityHashCode(sameVariable), newVarType);
+ Map updateVars = getUpdateSet(updateFromVariable, sameVariable);
+ for (Expression v : sameVariable) {
+ if (v != exp) {
+ if (v instanceof Variable) {
+ ((Variable) v).setType(newVarType);
+ updateVars.put(System.identityHashCode(v), v);
+ } else if (v instanceof Term) {
+ ((Term) v).setType(newVarType);
+ updateVars.put(System.identityHashCode(v), v);
+ }
+ }
+ }
+ } else {
+ Map updateVars = getUpdateSet(updateFromVariable, sameVariable);
+ for (Expression v : sameVariable) {
+ if (v instanceof Variable) {
+ Type orgVarType = ((Variable) v).getType();
+ if (orgVarType != varType && compareTypes(orgVarType, varType)) {
+ ((Variable) v).setType(varType);
+ updateVars.put(System.identityHashCode(v), v);
+ }
+ } else if (v instanceof Term) {
+ Type orgVarType = ((Term) v).getType();
+ if (orgVarType != varType && compareTypes(orgVarType, varType)) {
+ ((Term) v).setType(varType);
+ updateVars.put(System.identityHashCode(v), v);
+ }
+ }
+ }
+ }
+ }
+
+ private static void updateMessageTypes(Expression exp,
+ Map, Type>>> messages,
+ Map> expToMessage, Map> updateFromMessage) {
+ List messageExps = expToMessage.get(System.identityHashCode(exp));
+ if (messageExps == null) return;
+ Type msgType = null;
+ Map.Entry, Type> expsAndType = null;
+ for (Channel c : messages.keySet()) {
+ for (int i : messages.get(c).keySet()) {
+ expsAndType = messages.get(c).get(i);
+ if (expsAndType.getKey() == messageExps) {
+ msgType = expsAndType.getValue();
+ break;
+ }
+ }
+ if (msgType != null) break;
+ }
+ if (msgType == null) return;
+ Type newMsgType = getExpTypeIfUpdatable(msgType, exp);
+ if (newMsgType != null) {
+ expsAndType.setValue(newMsgType);
+ Map updateExps = getUpdateSet(updateFromMessage, messageExps);
+ for (Expression e : messageExps) {
+ if (e != exp) {
+ if (e instanceof Variable) {
+ ((Variable) e).setType(newMsgType);
+ updateExps.put(System.identityHashCode(e), e);
+ } else if (e instanceof Term) {
+ ((Term) e).setType(newMsgType);
+ updateExps.put(System.identityHashCode(e), e);
+ }
+ }
+ }
+ }
+ }
+
+ private static void updateConsOrSetTypes(Expression exp, Map consOrSet,
+ Map>> expToConsOrSet, Map> updateFromConsOrSet) {
+ Set> consComponentGroups = expToConsOrSet.get(System.identityHashCode(exp));
+ if (consComponentGroups == null) return;
+ for (List consOrSetComponentGroup: consComponentGroups) {
+ int idx = consOrSetComponentGroup.indexOf(exp);
+ switch (idx) {
+ case 0:
+ // exp is a list itself.
+ if (!(exp instanceof Term)) break;
+ Type listType = consOrSet.get(System.identityHashCode(consOrSetComponentGroup));
+ Type expType = getExpTypeIfUpdatable(listType, exp);
+ if (expType != null) {
+ consOrSet.put(System.identityHashCode(consOrSetComponentGroup), expType);
+ Map updateExps = getUpdateSet(updateFromConsOrSet, consOrSetComponentGroup);
+ if (consOrSetComponentGroup.get(2) instanceof Variable) {
+ ((Variable) consOrSetComponentGroup.get(2)).setType(expType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(2)), consOrSetComponentGroup.get(2));
+ } else if (consOrSetComponentGroup.get(2) instanceof Term) {
+ ((Term) consOrSetComponentGroup.get(2)).setType(expType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(2)), consOrSetComponentGroup.get(2));
+ }
+ Type compType = listComponentTypes.get(expType);
+ if (consOrSetComponentGroup.get(1) != null && consOrSetComponentGroup.get(1) instanceof Variable) {
+ ((Variable) consOrSetComponentGroup.get(1)).setType(compType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(1)), consOrSetComponentGroup.get(1));
+ } else if (consOrSetComponentGroup.get(1) != null && consOrSetComponentGroup.get(1) instanceof Term) {
+ ((Term) consOrSetComponentGroup.get(1)).setType(compType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(1)), consOrSetComponentGroup.get(1));
+ }
+ }
+ break;
+ case 1:
+ // exp is a list's component.
+ listType = consOrSet.get(System.identityHashCode(consOrSetComponentGroup));
+ Type compType = listComponentTypes.get(listType);
+ Type newCompType = getExpTypeIfUpdatable(compType, exp);
+ if (newCompType != null) {
+ Type newListType = listTypes.get(newCompType);
+ if (newListType == null) {
+ // Create new list type.
+ newListType = createNewListType(newCompType, listType);
+ }
+ consOrSet.put(System.identityHashCode(consOrSetComponentGroup), newListType);
+ Map updateExps = getUpdateSet(updateFromConsOrSet, consOrSetComponentGroup);
+ if (consOrSetComponentGroup.get(0) instanceof Term) {
+ ((Term) consOrSetComponentGroup.get(0)).setType(newListType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(0)), consOrSetComponentGroup.get(0));
+ }
+ if (consOrSetComponentGroup.get(2) instanceof Variable) {
+ ((Variable) consOrSetComponentGroup.get(2)).setType(newListType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(2)), consOrSetComponentGroup.get(2));
+ } else if (consOrSetComponentGroup.get(2) instanceof Term) {
+ ((Term) consOrSetComponentGroup.get(2)).setType(newListType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(2)), consOrSetComponentGroup.get(2));
+ }
+ }
+ break;
+ case 2:
+ // exp is a list itself.
+ listType = consOrSet.get(System.identityHashCode(consOrSetComponentGroup));
+ expType = getExpTypeIfUpdatable(listType, exp);
+ if (expType != null) {
+ consOrSet.put(System.identityHashCode(consOrSetComponentGroup), expType);
+ Map updateExps = getUpdateSet(updateFromConsOrSet, consOrSetComponentGroup);
+ if (consOrSetComponentGroup.get(0) instanceof Term) {
+ ((Term) consOrSetComponentGroup.get(0)).setType(expType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(0)), consOrSetComponentGroup.get(0));
+ }
+ compType = listComponentTypes.get(expType);
+ if (consOrSetComponentGroup.get(1) != null && consOrSetComponentGroup.get(1) instanceof Variable) {
+ ((Variable) consOrSetComponentGroup.get(1)).setType(compType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(1)), consOrSetComponentGroup.get(1));
+ } else if (consOrSetComponentGroup.get(1) != null && consOrSetComponentGroup.get(1) instanceof Term) {
+ ((Term) consOrSetComponentGroup.get(1)).setType(compType);
+ updateExps.put(System.identityHashCode(consOrSetComponentGroup.get(1)), consOrSetComponentGroup.get(1));
+ }
+ }
+ }
+ }
+ }
+
+ private static void updateTupleTypes(Expression exp, Map tuple,
+ Map>> expToTuple, Map> updateFromTuple) {
+ Set> tupleComponentGroups = expToTuple.get(System.identityHashCode(exp));
+ if (tupleComponentGroups == null) return;
+ for (List tupleComponentGroup: tupleComponentGroups) {
+ int idx = tupleComponentGroup.indexOf(exp);
+ if (idx == 0) {
+ // exp is a tuple itself.
+ Type tupleType = tuple.get(System.identityHashCode(tupleComponentGroup));
+ Type newTupleType = getExpTypeIfUpdatable(tupleType, exp);
+ if (newTupleType != null) {
+ // Propagate an update of a tuple's type to its components' types.
+ tuple.put(System.identityHashCode(tupleComponentGroup), newTupleType);
+ List componentTypes = tupleComponentTypes.get(newTupleType);
+ Map updateExps = getUpdateSet(updateFromTuple, tupleComponentGroup);
+ for (int i = 1; i < tupleComponentGroup.size(); i++) {
+ Expression compExp = tupleComponentGroup.get(i);
+ if (compExp instanceof Variable) {
+ Type compType = ((Variable) compExp).getType();
+ if (compType != null && DataConstraintModel.typeTuple.isAncestorOf(compType)) {
+ // If the type of one component (compExp) is also tuple.
+ Type newExpType = tupleTypes.get(componentTypes.subList(i - 1, componentTypes.size()));
+ if (newExpType == null) {
+ // Create new tuple type;
+ newExpType = createNewTupleType(componentTypes.subList(i - 1, componentTypes.size()), compType);
+ }
+ if (compareTypes(compType, newExpType)) {
+ ((Variable) compExp).setType(newExpType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else {
+ if (i - 1 < componentTypes.size()) {
+ if (compareTypes(compType, componentTypes.get(i - 1))) {
+ ((Variable) compExp).setType(componentTypes.get(i - 1));
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else {
+ // for insert
+ if (compareTypes(compType, newTupleType)) {
+ ((Variable) compExp).setType(newTupleType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ }
+ }
+ } else if (compExp instanceof Term) {
+ Type compType = ((Term) compExp).getType();
+ if (compType != null && DataConstraintModel.typeTuple.isAncestorOf(compType)) {
+ // If the type of one component (compExp) is also tuple.
+ Type newExpType = tupleTypes.get(componentTypes.subList(i - 1, componentTypes.size()));
+ if (newExpType == null) {
+ // Create new tuple type;
+ newExpType = createNewTupleType(componentTypes.subList(i - 1, componentTypes.size()), compType);
+ }
+ if (compareTypes(compType, newExpType)) {
+ ((Term) compExp).setType(newExpType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else {
+ if (i - 1 < componentTypes.size()) {
+ if (compareTypes(compType, componentTypes.get(i - 1))) {
+ ((Term) compExp).setType(componentTypes.get(i - 1));
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else {
+ // for insert
+ if (compareTypes(compType, newTupleType)) {
+ ((Term) compExp).setType(newTupleType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ }
+ }
+ }
+ }
+ }
+ } else {
+ // exp is a tuple's component.
+ Type tupleType = tuple.get(System.identityHashCode(tupleComponentGroup));
+ List componentTypes = tupleComponentTypes.get(tupleType);
+ boolean updated = false;
+ if (idx == 1) {
+ Type compType = componentTypes.get(idx - 1);
+ Type newCompType = getExpTypeIfUpdatable(compType, exp);
+ if (newCompType != null) {
+ componentTypes = new ArrayList<>(componentTypes);
+ componentTypes.set(idx - 1, newCompType);
+ updated = true;
+ }
+ } else {
+ Type expType = null;
+ if (exp instanceof Term) {
+ expType = ((Term) exp).getType();
+ } else if (exp instanceof Variable) {
+ expType = ((Variable) exp).getType();
+ }
+ if (expType != null && DataConstraintModel.typeTuple.isAncestorOf(expType)) {
+ // If the type of the updated component (exp) is also tuple.
+ List subCompTypes = tupleComponentTypes.get(expType);
+ componentTypes = new ArrayList<>(componentTypes);
+ for (int i = 0; i < subCompTypes.size(); i++) {
+ if (componentTypes.size() < i + 2) {
+ componentTypes.add(subCompTypes.get(i));
+ updated = true;
+ } else if (compareTypes(componentTypes.get(i + 1), subCompTypes.get(i))) {
+ componentTypes.set(i + 1, subCompTypes.get(i));
+ updated = true;
+ }
+ }
+ } else {
+ Type compType = componentTypes.get(idx - 1);
+ Type newCompType = getExpTypeIfUpdatable(compType, exp);
+ if (newCompType != null) {
+ componentTypes = new ArrayList<>(componentTypes);
+ componentTypes.set(idx - 1, newCompType);
+ updated = true;
+ }
+ }
+ }
+ if (updated) {
+ // Propagate an update of a component's type to its container's (tuple's) type.
+ Type newTupleType = tupleTypes.get(componentTypes);
+ if (newTupleType == null) {
+ // Create new tuple type;
+ newTupleType = createNewTupleType(componentTypes, tupleType);
+ }
+ Map updateExps = getUpdateSet(updateFromTuple, tupleComponentGroup);
+ Expression tupleExp = tupleComponentGroup.get(0);
+ if (tupleExp instanceof Variable) {
+ ((Variable) tupleExp).setType(newTupleType);
+ updateExps.put(System.identityHashCode(tupleExp), tupleExp);
+ } else if (tupleExp instanceof Term) {
+ ((Term) tupleExp).setType(newTupleType);
+ updateExps.put(System.identityHashCode(tupleExp), tupleExp);
+ }
+ tuple.put(System.identityHashCode(tupleComponentGroup), newTupleType);
+ }
+ }
+ }
+ }
+
+ private static void updatePairTypes(Expression exp, Map pair,
+ Map>> expToPair, Map> updateFromPair) {
+ Set> pairComponentGroups = expToPair.get(System.identityHashCode(exp));
+ if (pairComponentGroups == null) return;
+ for (List pairComponentGroup: pairComponentGroups) {
+ int idx = pairComponentGroup.indexOf(exp);
+ if (idx == 0) {
+ // exp is a pair itself.
+ Type pairType = pair.get(System.identityHashCode(pairComponentGroup));
+ Type newPairType = getExpTypeIfUpdatable(pairType, exp);
+ if (newPairType != null) {
+ // Propagate an update of a pair's type to its components' types.
+ pair.put(System.identityHashCode(pairComponentGroup), newPairType);
+ Type componentType = pairComponentTypes.get(newPairType);
+ Map updateExps = getUpdateSet(updateFromPair, pairComponentGroup);
+ for (int i = 1; i < pairComponentGroup.size(); i++) {
+ Expression compExp = pairComponentGroup.get(i);
+ if (compExp instanceof Variable) {
+ if (compareTypes(((Variable) compExp).getType(), componentType)) {
+ ((Variable) compExp).setType(componentType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else if (compExp instanceof Term) {
+ if (compareTypes(((Term) compExp).getType(), componentType)) {
+ ((Term) compExp).setType(componentType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ }
+ }
+ }
+ } else {
+ // exp is a pair's component.
+ Type pairType = pair.get(System.identityHashCode(pairComponentGroup));
+ Type compType = pairComponentTypes.get(pairType);
+ Type newCompType = getExpTypeIfUpdatable(compType, exp);
+ if (newCompType != null) {
+ // Propagate an update of a component's type to its container's (pair's) type.
+ Type newPairType = pairTypes.get(compType);
+ if (newPairType != null) {
+ Map updateExps = getUpdateSet(updateFromPair, pairComponentGroup);
+ Expression pairExp = pairComponentGroup.get(0);
+ if (pairExp instanceof Variable) {
+ ((Variable) pairExp).setType(newPairType);
+ updateExps.put(System.identityHashCode(pairExp), pairExp);
+ } else if (pairExp instanceof Term) {
+ ((Term) pairExp).setType(newPairType);
+ updateExps.put(System.identityHashCode(pairExp), pairExp);
+ }
+ pair.put(System.identityHashCode(pairComponentGroup), newPairType);
+ }
+ }
+ }
+ }
+ }
+
+ private static void updateMapTypes(Expression exp, Map map,
+ Map>> expToMap, Map> updateFromMap) {
+ Set> mapComponentGroups = expToMap.get(System.identityHashCode(exp));
+ if (mapComponentGroups == null) return;
+ for (List mapComponentGroup: mapComponentGroups) {
+ int idx = mapComponentGroup.indexOf(exp);
+ if (idx == 0 || idx == 3) {
+ // exp is a map itself.
+ Type mapType = map.get(System.identityHashCode(mapComponentGroup));
+ Type newMapType = getExpTypeIfUpdatable(mapType, exp);
+ if (newMapType != null) {
+ // Propagate an update of a map's type to its components' types.
+ map.put(System.identityHashCode(mapComponentGroup), newMapType);
+ List componentTypes = mapComponentTypes.get(newMapType);
+ Map updateExps = getUpdateSet(updateFromMap, mapComponentGroup);
+ for (int i = 1; i < mapComponentGroup.size() && i < 3; i++) {
+ Expression compExp = mapComponentGroup.get(i);
+ if (compExp instanceof Variable) {
+ if (compareTypes(((Variable) compExp).getType(), componentTypes.get(i - 1))) {
+ ((Variable) compExp).setType(componentTypes.get(i - 1));
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else if (compExp instanceof Term) {
+ if (compareTypes(((Term) compExp).getType(), componentTypes.get(i - 1))) {
+ ((Term) compExp).setType(componentTypes.get(i - 1));
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ }
+ }
+ // Propagate an update of a map's type to another map's type.
+ Expression compExp = null;
+ if (idx == 0 && mapComponentGroup.size() == 4) { // for insert
+ compExp = mapComponentGroup.get(3);
+ } else if (idx == 3) {
+ compExp = mapComponentGroup.get(0);
+ }
+ if (compExp != null) {
+ if (compExp instanceof Variable) {
+ if (compareTypes(((Variable) compExp).getType(), newMapType)) {
+ ((Variable) compExp).setType(newMapType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ } else if (compExp instanceof Term) {
+ if (compareTypes(((Term) compExp).getType(), newMapType)) {
+ ((Term) compExp).setType(newMapType);
+ updateExps.put(System.identityHashCode(compExp), compExp);
+ }
+ }
+ }
+ }
+ } else {
+ // exp is a map's key or value.
+ Type mapType = map.get(System.identityHashCode(mapComponentGroup));
+ List componentTypes = mapComponentTypes.get(mapType);
+ Type compType = componentTypes.get(idx - 1);
+ Type newCompType = getExpTypeIfUpdatable(compType, exp);
+ if (newCompType != null) {
+ // Propagate an update of a component's type to its container's (map's) type.
+ componentTypes = new ArrayList<>(componentTypes);
+ componentTypes.set(idx - 1, newCompType);
+ Type newMapType = mapTypes.get(componentTypes);
+ if (newMapType == null) {
+ // Create new map type;
+ newMapType = createNewMapType(componentTypes, mapType);
+ }
+ Map updateExps = getUpdateSet(updateFromMap, mapComponentGroup);
+ Expression mapExp = mapComponentGroup.get(0);
+ if (mapExp instanceof Variable) {
+ ((Variable) mapExp).setType(newMapType);
+ updateExps.put(System.identityHashCode(mapExp), mapExp);
+ } else if (mapExp instanceof Term) {
+ ((Term) mapExp).setType(newMapType);
+ updateExps.put(System.identityHashCode(mapExp), mapExp);
+ }
+ if (mapComponentGroup.size() == 4) { // for insert
+ mapExp = mapComponentGroup.get(3);
+ if (mapExp instanceof Variable) {
+ ((Variable) mapExp).setType(newMapType);
+ updateExps.put(System.identityHashCode(mapExp), mapExp);
+ } else if (mapExp instanceof Term) {
+ ((Term) mapExp).setType(newMapType);
+ updateExps.put(System.identityHashCode(mapExp), mapExp);
+ }
+ }
+ map.put(System.identityHashCode(mapComponentGroup), newMapType);
+ }
+ }
+ }
+ }
+
+
+ private static void updateJsonTypes(Expression exp, Map json,
+ Map>> expToJson, Map> updateFromJson) {
+ Set> jsonMemberGroups = expToJson.get(System.identityHashCode(exp));
+ if (jsonMemberGroups == null) return;
+ for (List jsonMemberGroup: jsonMemberGroups) {
+ int idx = jsonMemberGroup.indexOf(exp);
+ if (idx == 3) {
+ // exp is a json argument (0:t = addMember(3:json, 1:key, 2:value)).
+ Type jsonType = json.get(System.identityHashCode(jsonMemberGroup));
+ Map memberTypes = new HashMap<>(jsonMemberTypes.get(jsonType));
+ Map argMemberTypes = new HashMap<>(memberTypes);
+ String keyName = null;
+ Type valueType = null;
+ if (jsonMemberGroup.get(1) instanceof Constant) {
+ keyName = ((Constant) jsonMemberGroup.get(1)).getSymbol().getName();
+ valueType = ((Constant) jsonMemberGroup.get(1)).getType();
+ argMemberTypes.remove(keyName);
+ }
+ Type jsonArgType = jsonTypes.get(argMemberTypes);
+ Type newJsonArgType = getExpTypeIfUpdatable(jsonArgType, exp);
+ if (newJsonArgType != null && keyName != null) {
+ // Propagate an update of a json arg's type to its container's (json's) type.
+ argMemberTypes = ((JsonType) newJsonArgType).getMemberTypes();
+ argMemberTypes.put(keyName, valueType);
+ memberTypes.putAll(argMemberTypes);
+ Type newJsonType = jsonTypes.get(memberTypes);
+ if (newJsonType == null) {
+ // Create new json type.
+ newJsonType = createNewJsonType(memberTypes, jsonType);
+ }
+ // Update the type of the json term and record the updated expression.
+ Map updateExps = getUpdateSet(updateFromJson, jsonMemberGroup);
+ Expression jsonExp = jsonMemberGroup.get(0);
+ if (jsonExp instanceof Variable) {
+ ((Variable) jsonExp).setType(newJsonType);
+ updateExps.put(System.identityHashCode(jsonExp), jsonExp);
+ } else if (jsonExp instanceof Term) {
+ ((Term) jsonExp).setType(newJsonType);
+ updateExps.put(System.identityHashCode(jsonExp), jsonExp);
+ }
+ json.put(System.identityHashCode(jsonMemberGroup), newJsonType);
+ }
+ } else if (idx == 2) {
+ // exp is a value (0:t = addMember(3:json, 1:key, 2:value) or 2:value = dot(0:list/map, 1:key)).
+ Type jsonType = json.get(System.identityHashCode(jsonMemberGroup));
+ Type newJsonType = null;
+ if (exp instanceof Term && ((Term) exp).getSymbol().equals(DataConstraintModel.dotParam)) {
+ if (DataConstraintModel.typeList.isAncestorOf(jsonType)) {
+ Type elementType = listComponentTypes.get(jsonType);
+ Type newElementType = getExpTypeIfUpdatable(elementType, exp);
+ if (newElementType != null) {
+ // Propagate an update of a member's type to its container's (json's) type.
+ newJsonType = listTypes.get(newElementType);
+ if (newJsonType == null) {
+ // Create new json type.
+ newJsonType = createNewListType(newElementType, jsonType);
+ }
+ }
+ } else if (DataConstraintModel.typeMap.isAncestorOf(jsonType)) {
+ List keyValueTypes = mapComponentTypes.get(jsonType);
+ Type newValueType = getExpTypeIfUpdatable(keyValueTypes.get(1), exp);
+ if (newValueType != null) {
+ // Propagate an update of a member's type to its container's (json's) type.
+ List newKeyValueTypes = Arrays.asList(new Type[] {DataConstraintModel.typeString, newValueType});
+ newJsonType = mapTypes.get(newKeyValueTypes);
+ if (newJsonType == null) {
+ // Create new json type.
+ newJsonType = createNewMapType(newKeyValueTypes, jsonType);
+ }
+ }
+ }
+ } else {
+ Map memberTypes = jsonMemberTypes.get(jsonType);
+ String keyName = null;
+ if (jsonMemberGroup.get(1) instanceof Constant) {
+ keyName = ((Constant) jsonMemberGroup.get(1)).getSymbol().getName();
+ }
+ if (memberTypes != null) {
+ Type memberType = memberTypes.get(keyName);
+ Type newMemberType = getExpTypeIfUpdatable(memberType, exp);
+ if (newMemberType != null && keyName != null) {
+ // Propagate an update of a member's type to its container's (json's) type.
+ Map newMemberTypes = new HashMap<>(memberTypes);
+ newMemberTypes.put(keyName, newMemberType);
+ newJsonType = jsonTypes.get(newMemberTypes);
+ if (newJsonType == null) {
+ // Create new json type.
+ newJsonType = createNewJsonType(newMemberTypes, jsonType);
+ }
+ }
+ }
+ }
+ if (newJsonType != null) {
+ // Update the type of the json term and record the updated expression.
+ Map updateExps = getUpdateSet(updateFromJson, jsonMemberGroup);
+ Expression jsonExp = jsonMemberGroup.get(0);
+ if (jsonExp instanceof Variable) {
+ ((Variable) jsonExp).setType(newJsonType);
+ updateExps.put(System.identityHashCode(jsonExp), jsonExp);
+ } else if (jsonExp instanceof Term) {
+ ((Term) jsonExp).setType(newJsonType);
+ updateExps.put(System.identityHashCode(jsonExp), jsonExp);
+ }
+ json.put(System.identityHashCode(jsonMemberGroup), newJsonType);
+ }
+ }
+ }
+ }
+
+ private static Type createNewListType(Type compType, Type parentType) {
+ String compTypeName = getInterfaceTypeName(compType);
+ List childrenTypes = getChildrenTypes(parentType, listComponentTypes.keySet());
+ Type newListType = new Type("List", "ArrayList<>", "List<" + compTypeName + ">", parentType);
+ listTypes.put(compType, newListType);
+ listComponentTypes.put(newListType, compType);
+ for (Type childType : childrenTypes) {
+ if (compareTypes(childType, newListType)) {
+ if (newListType.getParentTypes().contains(parentType)) {
+ newListType.replaceParentType(parentType, childType);
+ } else {
+ newListType.addParentType(childType);
+ }
+ } else if (compareTypes(newListType, childType)) {
+ childType.replaceParentType(parentType, newListType);
+ }
+ }
+ return newListType;
+ }
+
+ private static Type createNewTupleType(List componentTypes, Type parentTupleType) {
+ String implTypeName = "AbstractMap.SimpleEntry<>";
+ String interfaceTypeName = "Map.Entry<$x>";
+ if (componentTypes.size() >= 2) {
+ implTypeName = implTypeName.replace("$x", getImplementationTypeName(componentTypes.get(0)) + "$x");
+ interfaceTypeName = interfaceTypeName.replace("$x", getInterfaceTypeName(componentTypes.get(0)) + "$x");
+ for (Type argType : componentTypes.subList(1, componentTypes.size() - 1)) {
+ implTypeName = implTypeName.replace("$x",
+ ", AbstractMap.SimpleEntry<" + getImplementationTypeName(argType) + "$x>");
+ interfaceTypeName = interfaceTypeName.replace("$x",
+ ", Map.Entry<" + getInterfaceTypeName(argType) + "$x>");
+ }
+ implTypeName = implTypeName.replace("$x",
+ ", " + getImplementationTypeName(componentTypes.get(componentTypes.size() - 1)));
+ interfaceTypeName = interfaceTypeName.replace("$x",
+ ", " + getInterfaceTypeName(componentTypes.get(componentTypes.size() - 1)));
+ }
+ List childrenTypes = getChildrenTypes(parentTupleType, tupleComponentTypes.keySet());
+ Type newTupleType = new Type("Tuple", implTypeName, interfaceTypeName, parentTupleType);
+ tupleTypes.put(componentTypes, newTupleType);
+ tupleComponentTypes.put(newTupleType, componentTypes);
+ for (Type childType : childrenTypes) {
+ if (compareTypes(childType, newTupleType)) {
+ if (newTupleType.getParentTypes().contains(parentTupleType)) {
+ newTupleType.replaceParentType(parentTupleType, childType);
+ } else {
+ newTupleType.addParentType(childType);
+ }
+ } else if (compareTypes(newTupleType, childType)) {
+ childType.replaceParentType(parentTupleType, newTupleType);
+ }
+ }
+ return newTupleType;
+ }
+
+ private static Type createNewMapType(List componentTypes, Type parentMapType) {
+ String implTypeName = "HashMap<>";
+ String interfaceTypeName = "Map<$x, $y>";
+ if (componentTypes.size() == 2) {
+ implTypeName = implTypeName.replace("$x", getImplementationTypeName(componentTypes.get(0)));
+ interfaceTypeName = interfaceTypeName.replace("$x", getInterfaceTypeName(componentTypes.get(0)));
+ implTypeName = implTypeName.replace("$y", getImplementationTypeName(componentTypes.get(1)));
+ interfaceTypeName = interfaceTypeName.replace("$y", getInterfaceTypeName(componentTypes.get(1)));
+ }
+ List childrenTypes = getChildrenTypes(parentMapType, mapComponentTypes.keySet());
+ Type newMapType = new Type("Map", implTypeName, interfaceTypeName, parentMapType);
+ mapTypes.put(componentTypes, newMapType);
+ mapComponentTypes.put(newMapType, componentTypes);
+ for (Type childType : childrenTypes) {
+ if (compareTypes(childType, newMapType)) {
+ if (newMapType.getParentTypes().contains(parentMapType)) {
+ newMapType.replaceParentType(parentMapType, childType);
+ } else {
+ newMapType.addParentType(childType);
+ }
+ } else if (compareTypes(newMapType, childType)) {
+ childType.replaceParentType(parentMapType, newMapType);
+ }
+ }
+ return newMapType;
+ }
+
+ private static JsonType createNewJsonType(Map memberTypes, Type parentJsonType) {
+ String implTypeName = "HashMap<>";
+ String interfaceTypeName = "Map";
+ List childrenTypes = getChildrenTypes(parentJsonType, jsonMemberTypes.keySet());
+ JsonType newJsonType = new JsonType("Json", implTypeName, interfaceTypeName, parentJsonType);
+ for (String key: memberTypes.keySet()) {
+ newJsonType.addMemberType(key, memberTypes.get(key));
+ }
+ jsonTypes.put(memberTypes, newJsonType);
+ jsonMemberTypes.put(newJsonType, memberTypes);
+ for (Type childType : childrenTypes) {
+ if (compareTypes(childType, newJsonType)) {
+ if (newJsonType.getParentTypes().contains(parentJsonType)) {
+ newJsonType.replaceParentType(parentJsonType, childType);
+ } else {
+ newJsonType.addParentType(childType);
+ }
+ } else if (compareTypes(newJsonType, childType)) {
+ childType.replaceParentType(parentJsonType, newJsonType);
+ }
+ }
+ return newJsonType;
+ }
+
+ /**
+ * Get children types of a given type from given set of types.
+ * @param parentType a type
+ * @param allTypes set of types
+ * @return list of the children types
+ */
+ private static List getChildrenTypes(Type parentType, Set allTypes) {
+ List childrenTypes = new ArrayList<>();
+ for (Type childType : allTypes) {
+ if (childType.getParentTypes().contains(parentType)) {
+ childrenTypes.add(childType);
+ }
+ }
+ return childrenTypes;
+ }
+
+ private static String getImplementationTypeName(Type type) {
+ if (type == null)
+ return "Object";
+ String wrapperType = DataConstraintModel.getWrapperType(type);
+ if (wrapperType != null)
+ return wrapperType;
+ return type.getImplementationTypeName();
+ }
+
+ private static String getInterfaceTypeName(Type type) {
+ if (type == null)
+ return "Object";
+ String wrapperType = DataConstraintModel.getWrapperType(type);
+ if (wrapperType != null)
+ return wrapperType;
+ return type.getInterfaceTypeName();
+ }
+
+ private static > Map getUpdateSet(Map> updateSets, U keySet) {
+ Map updatedExps = updateSets.get(System.identityHashCode(keySet));
+ if (updatedExps == null) {
+ updatedExps = new HashMap<>();
+ updateSets.put(System.identityHashCode(keySet), updatedExps);
+ }
+ return updatedExps;
+ }
+
+ private static Type getExpTypeIfUpdatable(Type originalType, Expression newExp) {
+ Type expType = null;
+ if (newExp instanceof Term) {
+ expType = ((Term) newExp).getType();
+ } else if (newExp instanceof Variable) {
+ expType = ((Variable) newExp).getType();
+ }
+ if (compareTypes(originalType, expType)) {
+ return expType;
+ }
+ return null;
+ }
+
+ /**
+ * Is an given original type an ancestor of a given new type?
+ *
+ * @param originalType original type
+ * @param newType new type (may not have been registered)
+ * @return true: if the original type equals to the new type or is an ancestor
+ * of the new type, false: otherwise
+ */
+ private static boolean compareTypes(Type originalType, Type newType) {
+ if (originalType == null) return true;
+ if (originalType != newType && newType != null) {
+ if (originalType.isAncestorOf(newType)) return true;
+ if (newType.isAncestorOf(originalType)) return false;
+ if (DataConstraintModel.typeMap.isAncestorOf(originalType)
+ && DataConstraintModel.typeMap.isAncestorOf(newType)) {
+ List originalCompTypes = mapComponentTypes.get(originalType);
+ List newCompTypes = mapComponentTypes.get(newType);
+ if (originalCompTypes == null) return true;
+ for (int i = 0; i < originalCompTypes.size(); i++) {
+ if (originalCompTypes.get(i) != null &&
+ (newCompTypes.get(i) == null || !originalCompTypes.get(i).isAncestorOf(newCompTypes.get(i)))) return false;
+ }
+ return true;
+ }
+ if (DataConstraintModel.typeTuple.isAncestorOf(originalType)
+ && DataConstraintModel.typeTuple.isAncestorOf(newType)) {
+ List originalCompTypes = tupleComponentTypes.get(originalType);
+ List newCompTypes = tupleComponentTypes.get(newType);
+ if (originalCompTypes == null) return true;
+ originalCompTypes = new ArrayList<>(originalCompTypes);
+ newCompTypes = new ArrayList<>(newCompTypes);
+ for (int i = 0; i < originalCompTypes.size(); i++) {
+ if (originalCompTypes.get(i) != null) {
+ if (DataConstraintModel.typeTuple.isAncestorOf(originalCompTypes.get(i))) {
+ // Unfold the nested tuple's types.
+ Type tupleType = originalCompTypes.remove(i);
+ for (Type t: tupleComponentTypes.get(tupleType)) {
+ originalCompTypes.add(t);
+ }
+ }
+ if (newCompTypes.size() - 1 < i) return false;
+ if (newCompTypes.get(i) != null && DataConstraintModel.typeTuple.isAncestorOf(newCompTypes.get(i))) {
+ // Unfold the nested tuple's types.
+ Type tupleType = newCompTypes.remove(i);
+ for (Type t: tupleComponentTypes.get(tupleType)) {
+ newCompTypes.add(t);
+ }
+ }
+ if (newCompTypes.get(i) == null || !originalCompTypes.get(i).isAncestorOf(newCompTypes.get(i))) return false;
+ }
+ }
+ return true;
+ }
+ if (DataConstraintModel.typeList.isAncestorOf(originalType)
+ && DataConstraintModel.typeList.isAncestorOf(newType)) {
+ Type originalCompType = listComponentTypes.get(originalType);
+ Type newCompType = listComponentTypes.get(newType);
+ if (originalCompType != null && (newCompType == null || !originalCompType.isAncestorOf(newCompType))) return false;
+ return true;
+ }
+ if (DataConstraintModel.typeJson.isAncestorOf(originalType) && DataConstraintModel.typeJson.isAncestorOf(newType)) {
+ Map originalMemberTypes = jsonMemberTypes.get(originalType);
+ Map newMemberTypes = jsonMemberTypes.get(newType);
+ if (originalMemberTypes == null) return true;
+ if (originalMemberTypes.keySet().size() < newMemberTypes.keySet().size()
+ && newMemberTypes.keySet().containsAll(originalMemberTypes.keySet())) return true;
+ if (originalMemberTypes.keySet().size() > newMemberTypes.keySet().size()) return false;
+ if (!newMemberTypes.keySet().containsAll(originalMemberTypes.keySet())) return false;
+ for (String key: originalMemberTypes.keySet()) {
+ if (!originalMemberTypes.get(key).isAncestorOf(newMemberTypes.get(key))) return false;
+ }
+ return true;
+ }
+ }
+ return false;
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/algorithms/Validation.java b/AlgebraicDataflowArchitectureModel/src/algorithms/Validation.java
new file mode 100644
index 0000000..1744af5
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/algorithms/Validation.java
@@ -0,0 +1,72 @@
+package algorithms;
+
+import java.util.*;
+
+import models.*;
+import models.dataFlowModel.*;
+
+/**
+ * Validation checker for data transfer model
+ *
+ * @author Nitta
+ *
+ */
+public class Validation {
+ private static int index = 0;
+ private static Deque stack = new ArrayDeque<>();
+ private static Set> strong = new HashSet<>();
+ private static Map ids = new HashMap<>();
+ private static Map lowlink = new HashMap<>();
+ private static Map onStack = new HashMap<>();
+
+ static public boolean checkUpdateConflict(DataTransferModel model) {
+ init();
+ boolean check = true;
+ for (Node node : model.getDataFlowGraph().getNodes()) {
+ if (ids.containsKey(node)) {
+ traverseStronglyConnectedComponents(node);
+ }
+ }
+ return strong.size() == 0 && check;
+ }
+
+ static private void init() {
+ index = 0;
+ stack = new ArrayDeque<>();
+ strong = new HashSet<>();
+ ids = new HashMap<>();
+ lowlink = new HashMap<>();
+ onStack = new HashMap<>();
+ }
+
+ static private void traverseStronglyConnectedComponents(Node node) {
+ ids.put(node, index);
+ lowlink.put(node, index);
+ index++;
+ stack.push(node);
+ onStack.put(node, true);
+
+ for (Node n : node.getSuccessors()) {
+ if (lowlink.containsKey(n)) {
+ traverseStronglyConnectedComponents(n);
+ if (lowlink.get(node) > lowlink.get(n)) {
+ lowlink.replace(node, lowlink.get(n));
+ }
+ } else if (onStack.get(n)) {
+ if (lowlink.get(node) > lowlink.get(n)) {
+ lowlink.replace(node, lowlink.get(n));
+ }
+ }
+ }
+ if (lowlink.get(node) == ids.get(node)) {
+ Set tmp = new HashSet<>();
+ Node w;
+ do {
+ w = stack.pop();
+ onStack.replace(node, false);
+ tmp.add(w);
+ } while (node != w);
+ strong.add(tmp);
+ }
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/ApplicationLanguage.java b/AlgebraicDataflowArchitectureModel/src/application/ApplicationLanguage.java
new file mode 100644
index 0000000..238f283
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/ApplicationLanguage.java
@@ -0,0 +1,84 @@
+package application;
+
+import java.io.File;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLClassLoader;
+import java.nio.file.Paths;
+import java.util.Locale;
+import java.util.ResourceBundle;
+
+/***********************************************************************
+ * アプリケーションの言語を切り替える（シングルトン）
+ */
+public class ApplicationLanguage {
+ private Locale locale = null;
+ private ResourceBundle resBundle = null;
+
+ private static ApplicationLanguage instance = null;
+
+ private final static String RESOURCE_PATH = "resources/locales/";
+
+ public final static String JP = "ja";
+ public final static String EN = "en";
+
+ /***********************************************************************
+ /***********************************************************************
+ * [ *constructor ]
+ /***********************************************************************
+ *
+ * @return
+ */
+ private ApplicationLanguage() {
+ this.locale = Locale.getDefault();
+ setLocaleLanguage(this.locale.getLanguage());
+ }
+
+ /***********************************************************************
+ /***********************************************************************
+ * [ *public static ]
+ /***********************************************************************
+ *
+ */
+ public static ApplicationLanguage getInstance() {
+ if (instance == null) instance = new ApplicationLanguage();
+ return instance;
+ }
+
+ /***********************************************************************
+ /***********************************************************************
+ * [ *public ]
+ /***********************************************************************
+ * ローカルの .properties から言語情報を切り替え.
+ * @param language 変更先の言語
+ */
+ public void setLocaleLanguage(final String language) {
+ URL resURL = null;
+ try {
+ File resDir = Paths.get(RESOURCE_PATH).toFile(); // for Eclipse project
+ resURL = resDir.toURI().toURL();
+ } catch (MalformedURLException e) {
+ e.printStackTrace();
+ }
+// resURL = this.getClass().getClassLoader().getResource(RESOURCE_PATH); // for executable jar
+ URLClassLoader urlLoader = new URLClassLoader(new URL[] { resURL });
+ this.resBundle = ResourceBundle.getBundle(language, this.locale, urlLoader);
+
+// // Another approach.
+// properties = new Properties();
+// try {
+// properties.load(Main.class.getClassLoader().getResourceAsStream(RESOURCE_PATH + language + ".properties"));
+// } catch (IOException e) {
+// return;
+// }
+ }
+
+ /***********************************************************************
+ * オプション名に対応した名前を返す.
+ * @param propName 取得したいプロパティの名前
+ */
+ public String getOptionByPropName(final String propName) {
+// return properties.getProperty(propName);
+ return this.resBundle.getString(propName);
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/ApplicationMenuBar.java b/AlgebraicDataflowArchitectureModel/src/application/ApplicationMenuBar.java
new file mode 100644
index 0000000..b63e9f8
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/ApplicationMenuBar.java
@@ -0,0 +1,100 @@
+package application;
+
+import javax.swing.JMenu;
+import javax.swing.JMenuBar;
+
+import application.actions.CircleLayoutAction;
+import application.actions.DAGLayoutAction;
+import application.actions.DeleteAction;
+import application.actions.ExitAction;
+import application.actions.JavaPrototypeGenerateAction;
+import application.actions.JerseyPrototypeGenerateAction;
+import application.actions.NewChannelAction;
+import application.actions.NewFormulaChannelAction;
+import application.actions.NewIOChannelAction;
+import application.actions.NewModelAction;
+import application.actions.NewResourceAction;
+import application.actions.OpenAction;
+import application.actions.SaveAction;
+import application.actions.SaveAsAction;
+import application.actions.ShowNavigationAction;
+import application.actions.ShowFlowLayerWindowAction;
+import application.actions.TreeLayoutAction;
+import application.actions.ZoomInAction;
+import application.actions.ZoomOutAction;
+import application.editor.Editor;
+
+public class ApplicationMenuBar extends JMenuBar {
+ private static final long serialVersionUID = 4811536194182272888L;
+
+ private ApplicationWindow applicationWindow = null;
+
+ private NewResourceAction newResourceAction = null;
+ private NewChannelAction newChannelAction = null;
+ private NewIOChannelAction newIOChannelAction = null;
+ private NewFormulaChannelAction newFormulaChannelAction = null;
+ private DeleteAction deleteAction = null;
+ private JavaPrototypeGenerateAction javaPrototypeGenerateAction = null;
+ private JerseyPrototypeGenerateAction jerseyPrototypeGenerateAction = null;
+ private DAGLayoutAction dagLayoutAction = null;
+ private TreeLayoutAction treeLayoutAction = null;
+ private CircleLayoutAction circleLayoutAction = null;
+
+ public ApplicationMenuBar(ApplicationWindow applicationWindow) {
+ this.applicationWindow = applicationWindow;
+ JMenu newMenu = new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("new"));
+
+ newMenu.add(new NewModelAction(applicationWindow));
+
+ newMenu.add(newResourceAction = new NewResourceAction(applicationWindow.getEditor()));
+ newMenu.add(newChannelAction = new NewChannelAction(applicationWindow.getEditor()));
+ newMenu.add(newIOChannelAction = new NewIOChannelAction(applicationWindow.getEditor()));
+ newMenu.add(newFormulaChannelAction = new NewFormulaChannelAction(applicationWindow.getEditor()));
+
+ JMenu menu = null;
+ menu = add(new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("file")));
+ menu.add(newMenu);
+ menu.add(new OpenAction(applicationWindow));
+ menu.addSeparator();
+ menu.add(new SaveAction(applicationWindow));
+ menu.add(new SaveAsAction(applicationWindow));
+ menu.addSeparator();
+ menu.add(new ExitAction());
+
+ menu = add(new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("edit")));
+ menu.add(deleteAction = new DeleteAction(applicationWindow.getEditor()));
+
+
+ menu = add(new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("layout")));
+ menu.add(dagLayoutAction = new DAGLayoutAction(applicationWindow.getEditor()));
+ menu.add(treeLayoutAction = new TreeLayoutAction(applicationWindow.getEditor()));
+ menu.add(circleLayoutAction = new CircleLayoutAction(applicationWindow.getEditor()));
+
+ menu = add(new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("view")));
+ menu.add(new ZoomInAction(applicationWindow.getGraphComponent()));
+ menu.add(new ZoomOutAction(applicationWindow.getGraphComponent()));
+
+ menu = add(new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("generate")));
+ menu.add(javaPrototypeGenerateAction = new JavaPrototypeGenerateAction(applicationWindow.getEditor()));
+ menu.add(jerseyPrototypeGenerateAction = new JerseyPrototypeGenerateAction(applicationWindow.getEditor()));
+
+ menu = add(new JMenu(ApplicationLanguage.getInstance().getOptionByPropName("window")));
+ menu.add(new ShowNavigationAction(applicationWindow));
+ menu.add(new ShowFlowLayerWindowAction(applicationWindow));
+ }
+
+ public Editor getEditor() {
+ return applicationWindow.getEditor();
+ }
+
+ public void setEditor(Editor editor) {
+ newResourceAction.setEditor(editor);
+ newChannelAction.setEditor(editor);
+ newIOChannelAction.setEditor(editor);
+ deleteAction.setEditor(editor);
+ javaPrototypeGenerateAction.setEditor(editor);
+ jerseyPrototypeGenerateAction.setEditor(editor);
+ treeLayoutAction.setEditor(editor);
+ circleLayoutAction.setEditor(editor);
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/ApplicationWindow.java b/AlgebraicDataflowArchitectureModel/src/application/ApplicationWindow.java
new file mode 100644
index 0000000..d4a58e1
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/ApplicationWindow.java
@@ -0,0 +1,117 @@
+package application;
+
+import java.io.IOException;
+import java.util.logging.FileHandler;
+import java.util.logging.Handler;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import java.util.logging.SimpleFormatter;
+
+import javax.swing.JFrame;
+
+import com.mxgraph.model.mxGeometry;
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.swing.handler.mxRubberband;
+import com.mxgraph.view.mxGraph;
+
+import application.editor.Editor;
+import application.views.NavigationWindow;
+import application.views.controlFlowDelegation.FlowLayerWindow;
+
+/**
+ * Application main window
+ *
+ * @author Nitta Lab.
+ *
+ */
+public class ApplicationWindow extends JFrame {
+ private static final long serialVersionUID = -8690140317781055614L;
+ public static final String title = "Visual Modeling Tool";
+ public static final Logger logger = Logger.getLogger("dtram");
+
+ private Editor editor = null;
+ private mxGraph graph = null;
+ private mxGraphComponent graphComponent = null;
+
+ private ApplicationMenuBar menuBar = null;
+ private NavigationWindow navigationWindow = null;
+ private FlowLayerWindow showFlowLayerWindow = null;
+
+ public ApplicationWindow() {
+ setTitle(title);
+ setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
+
+ try {
+ Handler fh = new FileHandler("dtram.log", true);
+ fh.setFormatter(new SimpleFormatter());
+ logger.addHandler(fh);
+ } catch (SecurityException | IOException e) {
+ e.printStackTrace();
+ }
+ logger.setLevel(Level.INFO);
+ logger.log(Level.INFO, "launched");
+
+ // If you want to change the language, change here.
+ ApplicationLanguage.getInstance().setLocaleLanguage(ApplicationLanguage.JP);
+
+ this.graph = new mxGraph() {
+ public boolean isPort(Object cell) {
+ mxGeometry geo = getCellGeometry(cell);
+
+ return (geo != null) ? geo.isRelative() : false;
+ }
+
+ public boolean isCellFoldable(Object cell, boolean collapse) {
+ return false;
+ }
+ };
+
+ this.graphComponent = new mxGraphComponent(graph);
+
+ this.editor = new Editor(graphComponent);
+
+ getContentPane().add(graphComponent);
+ new mxRubberband(graphComponent);
+ graph.setAllowDanglingEdges(false);
+ graph.setCellsDisconnectable(true);
+ graph.setDropEnabled(false);
+
+ menuBar = new ApplicationMenuBar(this);
+ setJMenuBar(menuBar);
+ setSize(870, 640);
+
+ navigationWindow = new NavigationWindow(this, editor);
+ navigationWindow.setVisible(true);
+
+ showFlowLayerWindow = new FlowLayerWindow(this);
+ showFlowLayerWindow.setVisible(false);
+
+ editor.addStageChangeListener(navigationWindow);
+ editor.addStageChangeListener(showFlowLayerWindow);
+ }
+
+ public mxGraph getGraph() {
+ return graph;
+ }
+
+ public mxGraphComponent getGraphComponent() {
+ return graphComponent;
+ }
+
+ public Editor getEditor() {
+ return editor;
+ }
+
+ public void setEditor(Editor editor) {
+ this.editor = editor;
+ }
+
+ public void showNavigationWindow() {
+ navigationWindow.setVisible(true);
+ }
+
+ public void showSwitchLayerWindow() {
+ showFlowLayerWindow.setVisible(true);
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractEditorAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractEditorAction.java
new file mode 100644
index 0000000..2db8692
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractEditorAction.java
@@ -0,0 +1,29 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.util.logging.Level;
+
+import javax.swing.AbstractAction;
+import javax.swing.Action;
+
+import application.ApplicationLanguage;
+import application.ApplicationWindow;
+import application.editor.Editor;
+
+public abstract class AbstractEditorAction extends AbstractAction {
+ protected Editor editor;
+
+ public AbstractEditorAction(String propName, Editor editor) {
+ super(ApplicationLanguage.getInstance().getOptionByPropName(propName));
+ this.editor = editor;
+ }
+
+ public void setEditor(Editor editor) {
+ this.editor = editor;
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ ApplicationWindow.logger.log(Level.INFO, (String) getValue(Action.NAME));
+ }
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractPopupAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractPopupAction.java
new file mode 100644
index 0000000..665fce0
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractPopupAction.java
@@ -0,0 +1,33 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.util.logging.Level;
+
+import javax.swing.AbstractAction;
+import javax.swing.Action;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+
+import application.ApplicationLanguage;
+import application.ApplicationWindow;
+
+public abstract class AbstractPopupAction extends AbstractAction {
+ protected mxGraphComponent graphComponent = null;
+ protected mxCell targetCell = null;
+
+ public AbstractPopupAction(final String propName, final mxCell targetCell, final mxGraphComponent graphComponent) {
+ super(ApplicationLanguage.getInstance().getOptionByPropName(propName));
+ this.graphComponent = graphComponent;
+ this.targetCell = targetCell;
+ }
+
+ public void updateTargetCell(final mxCell targetCell) {
+ this.targetCell = targetCell;
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ ApplicationWindow.logger.log(Level.INFO, (String) getValue(Action.NAME));
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractSystemAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractSystemAction.java
new file mode 100644
index 0000000..76b644b
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractSystemAction.java
@@ -0,0 +1,30 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.util.logging.Level;
+
+import javax.swing.AbstractAction;
+import javax.swing.Action;
+
+import application.ApplicationLanguage;
+import application.ApplicationWindow;
+import application.editor.Editor;
+
+public abstract class AbstractSystemAction extends AbstractAction {
+
+ protected ApplicationWindow frame;
+
+ public AbstractSystemAction(String propName, ApplicationWindow frame) {
+ super(ApplicationLanguage.getInstance().getOptionByPropName(propName));
+ this.frame = frame;
+ }
+
+ public void setFrame(ApplicationWindow frame) {
+ this.frame = frame;
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ ApplicationWindow.logger.log(Level.INFO, (String) getValue(Action.NAME));
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractViewerAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractViewerAction.java
new file mode 100644
index 0000000..f7a283d
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/AbstractViewerAction.java
@@ -0,0 +1,27 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.util.logging.Level;
+
+import javax.swing.AbstractAction;
+import javax.swing.Action;
+
+import com.mxgraph.swing.mxGraphComponent;
+
+import application.ApplicationLanguage;
+import application.ApplicationWindow;
+
+public abstract class AbstractViewerAction extends AbstractAction {
+
+ protected mxGraphComponent graphComponent = null;
+
+ public AbstractViewerAction(String propName, mxGraphComponent graphComponent) {
+ super(ApplicationLanguage.getInstance().getOptionByPropName(propName));
+ this.graphComponent = graphComponent;
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ ApplicationWindow.logger.log(Level.INFO, (String) getValue(Action.NAME));
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ChangeCallOrderAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ChangeCallOrderAction.java
new file mode 100644
index 0000000..75e4141
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ChangeCallOrderAction.java
@@ -0,0 +1,83 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.JOptionPane;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+
+import models.controlFlowModel.CallEdgeAttribute;
+
+/*************************************************************
+ *
+ */
+public class ChangeCallOrderAction extends AbstractPopupAction {
+
+ /*************************************************************
+ /*************************************************************
+ * [ *constructor ]
+ /*************************************************************
+ */
+ public ChangeCallOrderAction(final mxGraphComponent graphComponent ,final mxCell cell) {
+ super(/*propName*/"changeCallOrder", cell, graphComponent);
+ }
+
+ /*************************************************************
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ *
+ */
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ if(targetCell == null) return;
+ changeCallOrderOfCallEdge(targetCell);
+ }
+
+ /*************************************************************
+ /*************************************************************
+ * [ *private ]
+ /*************************************************************
+ * コントロールフローの呼び出し順を変更する
+ * @param cellObj 選択されたエッジ（コントロールフロー）のセル
+ */
+ private void changeCallOrderOfCallEdge(Object cellObj) {
+ String input = "";
+ int inputOrder = 0;
+
+ CallEdgeAttribute callEdgeAttr = (CallEdgeAttribute)graphComponent.getGraph().getModel().getValue(cellObj);
+ if (callEdgeAttr == null) return;
+
+ input = JOptionPane.showInputDialog("Call order");
+ if ( input == null) return;
+
+ if ( !isNumeric(input) ) {
+ JOptionPane.showMessageDialog(graphComponent, "Input value must type of number.");
+ return;
+ }
+
+ inputOrder = Integer.parseInt(input);
+
+ final int endOfOrderOfSrc = callEdgeAttr.getSourceObjectNode().getOutdegree();
+ if (inputOrder <= 0 || endOfOrderOfSrc < inputOrder) {
+ JOptionPane.showMessageDialog(graphComponent, "Input order must be between 1 and " + endOfOrderOfSrc + ".");
+ return;
+ }
+
+ int curOrder = callEdgeAttr.getSourceObjectNode().getOutEdgeCallOrder(callEdgeAttr.getCallEdge());
+ callEdgeAttr.getSourceObjectNode().sortOutEdgesByCallOrder(curOrder, inputOrder);
+
+ graphComponent.refresh();
+ }
+
+ /*************************************************************
+ * フォームに入力された文字列が数値か判定
+ * @param str フォームに入力された文字列
+ */
+ private boolean isNumeric(final String str) {
+ if (str == null) return false;
+ return str.matches("[0-9.]+");
+ }
+}
\ No newline at end of file
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/CircleLayoutAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/CircleLayoutAction.java
new file mode 100644
index 0000000..d19ff89
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/CircleLayoutAction.java
@@ -0,0 +1,19 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.editor.Editor;
+
+public class CircleLayoutAction extends AbstractEditorAction {
+
+ public CircleLayoutAction(Editor editor) {
+ super(/*propName*/"circleLayout", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ editor.setCircleLayout();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/DAGLayoutAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/DAGLayoutAction.java
new file mode 100644
index 0000000..a06c8f5
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/DAGLayoutAction.java
@@ -0,0 +1,19 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.editor.Editor;
+
+public class DAGLayoutAction extends AbstractEditorAction {
+
+ public DAGLayoutAction(Editor editor) {
+ super(/*propName*/"dagLayout", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ editor.setDAGLayout();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/DeleteAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/DeleteAction.java
new file mode 100644
index 0000000..7c949f0
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/DeleteAction.java
@@ -0,0 +1,25 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.ApplicationLanguage;
+import application.editor.Editor;
+
+public class DeleteAction extends AbstractEditorAction {
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = -4410145389391154784L;
+
+ public DeleteAction(Editor editor) {
+ super(/*propName*/ "delete", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ editor.delete();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ExitAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ExitAction.java
new file mode 100644
index 0000000..dcf6245
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ExitAction.java
@@ -0,0 +1,28 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.util.logging.Level;
+
+import javax.swing.AbstractAction;
+import javax.swing.Action;
+
+import application.ApplicationLanguage;
+import application.ApplicationWindow;
+
+public class ExitAction extends AbstractAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = -8733766417378036850L;
+
+ public ExitAction() {
+ super(ApplicationLanguage.getInstance().getOptionByPropName("exit"));
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ ApplicationWindow.logger.log(Level.INFO, "exit");
+ System.exit(0);
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/IntroduceMediatorObjectAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/IntroduceMediatorObjectAction.java
new file mode 100644
index 0000000..9aba67f
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/IntroduceMediatorObjectAction.java
@@ -0,0 +1,101 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.JOptionPane;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+
+import application.editor.stages.ControlFlowDelegationStage;
+import application.editor.stages.ControlFlowDelegationStageStatus;
+import models.controlFlowModel.ObjectNodeAttribute;
+
+/*************************************************************
+ *
+ */
+public class IntroduceMediatorObjectAction extends AbstractPopupAction{
+
+ private ControlFlowDelegationStage stage = null;
+
+ /************************************************************
+ /*************************************************************
+ * [ *constructor ]
+ /*************************************************************
+ */
+ public IntroduceMediatorObjectAction(final ControlFlowDelegationStage stage, final mxGraphComponent graphComponent ,final mxCell cell) {
+ super(/*propName*/"insertMediator", cell, graphComponent);
+ this.stage = stage;
+ }
+
+ /************************************************************
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ *
+ */
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ insertObjectNode(targetCell);
+ this.stage.setState( ControlFlowDelegationStageStatus.SELECTING_AN_EDGE);
+ }
+
+ /************************************************************
+ /************************************************************
+ * [ *private ]
+ /************************************************************
+ * 仲介者オブジェクトの導入を実行する.
+ * @param cellObj 選択されたエッジのセル
+ */
+ private void insertObjectNode(final Object cellObj) {
+ if (cellObj == null) return;
+
+ mxCell edgeCell = null;
+ if (cellObj instanceof mxCell) edgeCell = (mxCell)cellObj;
+ else return;
+
+ // Inputing name to the dialog.
+ String objName = JOptionPane.showInputDialog("Object Name:");
+ if (objName == null) return;
+
+ if (objName.isEmpty()) {
+ JOptionPane.showMessageDialog(graphComponent, "You must input a name. \nIt mustn't be empty.");
+ return;
+ }
+
+ if (isDuplicatedName(objName) ) {
+ JOptionPane.showMessageDialog(graphComponent, "The named object has already existed.");
+ return;
+ }
+
+ stage.insertObjectNodeCellInControlFlowLayer(edgeCell, objName);
+ }
+
+ /*************************************************************
+ * 同名のノードがすでにあるか判定する
+ * @param name つけたいノード名
+ */
+ private boolean isDuplicatedName(final String name) {
+ mxCell root = (mxCell)graphComponent.getGraph().getDefaultParent();
+
+ for (int i = 0; i < root.getChildCount(); i++) {
+ mxCell layerCell = (mxCell)root.getChildAt(i);
+
+ for (int j = 0; j < layerCell.getChildCount(); j++) {
+ mxCell cell = (mxCell)layerCell.getChildAt(j);
+
+ ObjectNodeAttribute attr = null;
+ if (cell.getValue() instanceof ObjectNodeAttribute)
+ attr = (ObjectNodeAttribute)cell.getValue();
+ else continue;
+
+ if ( !(attr.getObjectNode().getName().equals(name)) ) continue;
+ return true;
+ }
+ }
+ return false;
+ }
+
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/JavaPrototypeGenerateAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/JavaPrototypeGenerateAction.java
new file mode 100644
index 0000000..5cf13f9
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/JavaPrototypeGenerateAction.java
@@ -0,0 +1,104 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+
+import javax.swing.JFileChooser;
+
+import algorithms.*;
+import application.editor.Editor;
+import code.ast.*;
+import generators.CodeGenerator;
+import generators.CodeGeneratorFromControlFlowGraph;
+import generators.CodeGeneratorFromDataFlowGraph;
+import generators.DataTransferMethodAnalyzer;
+import generators.JavaCodeGenerator;
+import generators.JavaMethodBodyGenerator;
+import generators.JavaSpecific;
+import models.controlFlowModel.ControlFlowGraph;
+import models.dataConstraintModel.ResourcePath;
+import models.dataFlowModel.DataTransferModel;
+import models.dataFlowModel.ModelExtension;
+import models.dataFlowModel.DataFlowGraph;
+
+public class JavaPrototypeGenerateAction extends AbstractEditorAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = -3694103632055735068L;
+
+ private String lastDir = null;
+
+ public JavaPrototypeGenerateAction(Editor editor) {
+ super(/*propName*/"generateJava", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ DataFlowGraph dataFlowgraph = editor.getDataFlowGraph();
+ if (dataFlowgraph == null) {
+ editor.changeStage(Editor.STAGE_PUSH_PULL_SELECTION);
+ dataFlowgraph = editor.getDataFlowGraph();
+ }
+ if (dataFlowgraph != null) {
+ DataTransferModel model = editor.getModel();
+ ModelExtension.extendModel(model);
+ TypeInference.infer(model);
+ DataTransferMethodAnalyzer.decideToStoreResourceStates(dataFlowgraph);
+ String fileName = editor.getCurFileName();
+ if (fileName == null) fileName = "Main";
+ String mainTypeName = fileName.split("\\.")[0];
+ boolean exist = false;
+ for (ResourcePath id: model.getResourcePaths()) {
+ String resourceName = id.getResourceName().substring(0, 1).toUpperCase() + id.getResourceName().substring(1);
+ if (mainTypeName.equals(resourceName)) {
+ exist = true;
+ }
+ }
+ if (!exist) {
+ CodeGenerator.setMainTypeName(mainTypeName); // use model's file name as the main type's name.
+ } else {
+ CodeGenerator.resetMainTypeName(); // use the default main type's name.
+ }
+ ControlFlowGraph controlFlowGraph = editor.getControlFlowGraph();
+ if (controlFlowGraph != null) {
+ editor.setCodes(new CodeGeneratorFromControlFlowGraph().generateCode(model, controlFlowGraph, new JavaSpecific()));
+ } else {
+ editor.setCodes(new CodeGeneratorFromDataFlowGraph().generateCode(model, dataFlowgraph, new JavaSpecific()));
+ }
+ ModelExtension.recoverModel(model);
+ for (CompilationUnit file : editor.getCodes()) {
+ System.out.println(file);
+ }
+
+ String wd = (lastDir != null) ? lastDir : System.getProperty("user.dir");
+ JFileChooser fc = new JFileChooser(wd);
+ fc.setFileSelectionMode(JFileChooser.FILES_AND_DIRECTORIES);
+ int rc = fc.showSaveDialog(null);
+ if (rc == JFileChooser.APPROVE_OPTION) {
+ lastDir = fc.getSelectedFile().getPath();
+ for (CompilationUnit cu : editor.getCodes()) {
+ save(fc.getSelectedFile(), cu);
+ }
+ }
+ }
+ }
+
+ private void save(File dir, CompilationUnit cu) {
+ File javaFile = new File(dir.getPath(), cu.getFileName());
+ try {
+ BufferedWriter writer = new BufferedWriter(new FileWriter(javaFile));
+ writer.write(cu.toString());
+ writer.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/JerseyPrototypeGenerateAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/JerseyPrototypeGenerateAction.java
new file mode 100644
index 0000000..6ad55d2
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/JerseyPrototypeGenerateAction.java
@@ -0,0 +1,95 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+
+import javax.swing.JFileChooser;
+
+import algorithms.*;
+import application.editor.Editor;
+import code.ast.*;
+import generators.DataTransferMethodAnalyzer;
+import generators.JerseyCodeGenerator;
+import generators.JerseyMethodBodyGenerator;
+import models.algebra.Type;
+import models.dataConstraintModel.ResourcePath;
+import models.dataFlowModel.DataTransferModel;
+import models.dataFlowModel.ModelExtension;
+import models.dataFlowModel.DataFlowGraph;
+
+public class JerseyPrototypeGenerateAction extends AbstractEditorAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 1117065654665887436L;
+
+ private String lastDir = null;
+
+ public JerseyPrototypeGenerateAction(Editor editor) {
+ super(/*propName*/"generateJAX_RS", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ DataFlowGraph graph = editor.getDataFlowGraph();
+ if (graph == null) {
+ editor.changeStage(Editor.STAGE_PUSH_PULL_SELECTION);
+ graph = editor.getDataFlowGraph();
+ }
+ if (graph != null) {
+ DataTransferModel model = editor.getModel();
+ ModelExtension.extendModel(model);
+ TypeInference.infer(model);
+ DataTransferMethodAnalyzer.decideToStoreResourceStates(graph);
+ String fileName = editor.getCurFileName();
+ if (fileName == null) fileName = "Main";
+ String mainTypeName = fileName.split("\\.")[0];
+ boolean exist = false;
+ for (ResourcePath id: model.getResourcePaths()) {
+ String resourceName = id.getResourceName().substring(0, 1).toUpperCase() + id.getResourceName().substring(1);
+ if (mainTypeName.equals(resourceName)) {
+ exist = true;
+ }
+ }
+ if (!exist) {
+ JerseyCodeGenerator.setMainTypeName(mainTypeName); // use model's file name as the main type's name.
+ } else {
+ JerseyCodeGenerator.resetMainTypeName(); // use the default main type's name.
+ }
+ editor.setCodes(JerseyMethodBodyGenerator.doGenerate(graph, model, JerseyCodeGenerator.doGenerate(graph, model)));
+ ModelExtension.recoverModel(model);
+ for (CompilationUnit file : editor.getCodes()) {
+ System.out.println(file);
+ }
+
+ String wd = (lastDir != null) ? lastDir : System.getProperty("user.dir");
+ JFileChooser fc = new JFileChooser(wd);
+ fc.setFileSelectionMode(JFileChooser.FILES_AND_DIRECTORIES);
+ int rc = fc.showSaveDialog(null);
+ if (rc == JFileChooser.APPROVE_OPTION) {
+ lastDir = fc.getSelectedFile().getPath();
+ for (CompilationUnit cu : editor.getCodes()) {
+ save(fc.getSelectedFile(), cu);
+ }
+ }
+ }
+ }
+
+ private void save(File dir, CompilationUnit cu) {
+ File javaFile = new File(dir.getPath(), cu.getFileName());
+ try {
+ BufferedWriter writer = new BufferedWriter(new FileWriter(javaFile));
+ writer.write(cu.toString());
+ writer.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/NewChannelAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/NewChannelAction.java
new file mode 100644
index 0000000..2810dbc
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/NewChannelAction.java
@@ -0,0 +1,29 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.JOptionPane;
+
+import application.editor.Editor;
+import models.dataFlowModel.DataTransferChannel;
+
+public class NewChannelAction extends AbstractEditorAction {
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = 5979007029473101802L;
+
+ public NewChannelAction(Editor editor) {
+ super(/*propName*/"newChannel", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ String channelName = JOptionPane.showInputDialog("Channel Name:");
+ if (channelName == null) return;
+ editor.addChannel(new DataTransferChannel(channelName));
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/NewFormulaChannelAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/NewFormulaChannelAction.java
new file mode 100644
index 0000000..e524a8e
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/NewFormulaChannelAction.java
@@ -0,0 +1,63 @@
+package application.actions;
+
+import java.awt.BorderLayout;
+import java.awt.Container;
+import java.awt.FlowLayout;
+import java.awt.Frame;
+import java.awt.GridLayout;
+import java.awt.event.ActionEvent;
+import java.awt.event.ActionListener;
+
+import javax.swing.BoxLayout;
+import javax.swing.JButton;
+import javax.swing.JDialog;
+import javax.swing.JFrame;
+import javax.swing.JLabel;
+import javax.swing.JOptionPane;
+import javax.swing.JPanel;
+import javax.swing.JTextField;
+
+import application.ApplicationWindow;
+import application.editor.Editor;
+import models.visualModel.FormulaChannel;
+
+public class NewFormulaChannelAction extends AbstractEditorAction implements ActionListener {
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = 5345875219049178252L;
+
+ public NewFormulaChannelAction(Editor editor) {
+ super(/*propName*/"newFormulaChannel", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ JPanel panel = new JPanel();
+ GridLayout layout = new GridLayout(2,2);
+ panel.setLayout(layout);
+ layout.setVgap(5);
+ layout.setHgap(20);
+ panel.add(new JLabel("Channel Name:"));
+ JTextField channelText = new JTextField();
+ panel.add(channelText);
+ panel.add(new JLabel("Symbol:"));
+ JTextField symbolText = new JTextField();
+ panel.add(symbolText);
+
+ int r = JOptionPane.showConfirmDialog(
+ null,
+ panel,
+ "New Formula Channel",
+ JOptionPane.OK_CANCEL_OPTION,
+ JOptionPane.QUESTION_MESSAGE);
+
+ String channelName = channelText.getText();
+ String symbol = symbolText.getText();
+ if(r == JOptionPane.OK_OPTION) {
+ editor.addFormulaChannel(new FormulaChannel(channelName, editor.getModel().getSymbol(symbol)));
+ }
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/NewIOChannelAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/NewIOChannelAction.java
new file mode 100644
index 0000000..3d37ba4
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/NewIOChannelAction.java
@@ -0,0 +1,29 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.JOptionPane;
+
+import application.editor.Editor;
+import models.dataFlowModel.DataTransferChannel;
+
+public class NewIOChannelAction extends AbstractEditorAction {
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = -1657072017390171313L;
+
+ public NewIOChannelAction(Editor editor) {
+ super(/*propName*/"newEventChannel", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ String channelName = JOptionPane.showInputDialog("I/O Channel Name:");
+ if (channelName == null) return;
+ editor.addIOChannel(new DataTransferChannel(channelName));
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/NewModelAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/NewModelAction.java
new file mode 100644
index 0000000..77104a8
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/NewModelAction.java
@@ -0,0 +1,25 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.ApplicationWindow;
+import application.editor.Editor;
+
+public class NewModelAction extends AbstractSystemAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 8484493203589724589L;
+
+ public NewModelAction(ApplicationWindow frame) {
+ super(/*propName*/"newModel", frame);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ frame.getEditor().clear();
+ frame.setTitle(frame.title);
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/NewResourceAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/NewResourceAction.java
new file mode 100644
index 0000000..623e0b7
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/NewResourceAction.java
@@ -0,0 +1,29 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.JOptionPane;
+
+import application.editor.Editor;
+import models.dataConstraintModel.ResourcePath;
+
+public class NewResourceAction extends AbstractEditorAction {
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = -4439207504700741286L;
+
+ public NewResourceAction(Editor editor) {
+ super(/*propName*/"newResources", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ String resName = JOptionPane.showInputDialog("Resourece Name:");
+ if (resName == null) return;
+ editor.addResourcePath(new ResourcePath(resName, 0));
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/OpenAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/OpenAction.java
new file mode 100644
index 0000000..0502933
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/OpenAction.java
@@ -0,0 +1,63 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.io.File;
+
+import javax.swing.JFileChooser;
+import javax.swing.filechooser.FileFilter;
+import javax.swing.filechooser.FileNameExtensionFilter;
+
+import application.ApplicationWindow;
+import application.editor.Editor;
+
+public class OpenAction extends AbstractSystemAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = -8290761032629599683L;
+
+ private String lastDir = null;
+
+ public OpenAction(ApplicationWindow frame) {
+ super(/*propName*/"open", frame);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ Editor editor = frame.getEditor();
+ if (editor != null) {
+ String wd = (lastDir != null) ? lastDir : System.getProperty("user.dir");
+
+ JFileChooser fc = new JFileChooser(wd);
+
+ FileFilter model = new FileNameExtensionFilter("model","model");
+ FileFilter dtram = new FileNameExtensionFilter("dtram", "dtram");
+
+ // Adds file filter for supported file format
+ FileFilter defaultFilter = new FileFilter() {
+
+ public boolean accept(File file) {
+ String lcase = file.getName().toLowerCase();
+ return lcase.endsWith(".model");
+ }
+
+ @Override
+ public String getDescription() {
+ return null;
+ }
+ };
+
+ fc.addChoosableFileFilter(defaultFilter);
+ fc.addChoosableFileFilter(model);
+ fc.addChoosableFileFilter(dtram);
+ int rc = fc.showDialog(null, "Open Model File");
+ if (rc == JFileChooser.APPROVE_OPTION) {
+ lastDir = fc.getSelectedFile().getParent();
+ editor.open(fc.getSelectedFile());
+ frame.setTitle(frame.title + " - " + fc.getSelectedFile().getAbsolutePath());
+ }
+ }
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/SaveAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/SaveAction.java
new file mode 100644
index 0000000..c19d3bb
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/SaveAction.java
@@ -0,0 +1,27 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.ApplicationWindow;
+import application.editor.Editor;
+
+public class SaveAction extends AbstractSystemAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 5660460585305281982L;
+
+ public SaveAction(ApplicationWindow frame) {
+ super(/*propName*/"save", frame);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ Editor editor = frame.getEditor();
+ if (editor != null && editor.getCurFileName() != null) {
+ editor.save();
+ }
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/SaveAsAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/SaveAsAction.java
new file mode 100644
index 0000000..b527004
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/SaveAsAction.java
@@ -0,0 +1,78 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+import java.io.File;
+
+import javax.swing.AbstractAction;
+import javax.swing.JFileChooser;
+import javax.swing.filechooser.FileFilter;
+import javax.swing.filechooser.FileNameExtensionFilter;
+
+import application.ApplicationWindow;
+import application.editor.Editor;
+
+public class SaveAsAction extends AbstractSystemAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = -2599502783032684084L;
+
+ private String lastDir = null;
+
+ public SaveAsAction(ApplicationWindow frame) {
+ super(/*propName*/"saveAs", frame);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ Editor editor = frame.getEditor();
+ if (editor != null) {
+ String wd = (lastDir != null) ? lastDir : System.getProperty("user.dir");
+
+ JFileChooser fc = new JFileChooser(wd);
+ FileFilter model = new FileNameExtensionFilter("model","model");
+ FileFilter dtram = new FileNameExtensionFilter("dtram", "dtram");
+
+ // Adds file filter for supported file format
+ FileFilter defaultFilter = new FileFilter() {
+ public boolean accept(File file) {
+ String lcase = file.getName().toLowerCase();
+ return lcase.endsWith(".model");
+ }
+
+ @Override
+ public String getDescription() {
+ return null;
+ }
+ };
+
+ fc.addChoosableFileFilter(defaultFilter);
+ fc.addChoosableFileFilter(model);
+ fc.addChoosableFileFilter(dtram);
+ int rc = fc.showDialog(null, "Save Model File");
+
+ // choose a file extension from a dialog.
+ if (rc == JFileChooser.APPROVE_OPTION) {
+
+ // if extension filter is filled, then attaching extension by choosing filter.
+ // but if it's not filled, then using default extension name.
+ String extension = "";
+ if(fc.getFileFilter() instanceof FileNameExtensionFilter) {
+ FileNameExtensionFilter selectedFilter = (FileNameExtensionFilter)fc.getFileFilter();
+ extension = "." + selectedFilter.getExtensions()[0].toString();
+ }
+
+ lastDir = fc.getSelectedFile().getParent();
+
+ String fileName = fc.getSelectedFile().getAbsolutePath() + extension;
+ editor.setCurFilePath(fileName);
+
+ // overwriting file
+ editor.save();
+ frame.setTitle(ApplicationWindow.title + " - " + fc.getSelectedFile().getAbsolutePath());
+ }
+ }
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ShowDependentableMediatorAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ShowDependentableMediatorAction.java
new file mode 100644
index 0000000..8bba754
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ShowDependentableMediatorAction.java
@@ -0,0 +1,52 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+
+import application.editor.stages.ControlFlowDelegationStage;
+import application.editor.stages.ControlFlowDelegationStageStatus;
+import models.controlFlowModel.CallEdgeAttribute;
+
+public class ShowDependentableMediatorAction extends AbstractPopupAction {
+ private ControlFlowDelegationStage stage = null;
+
+ /*************************************************************
+ /*************************************************************
+ * [ *constructor ]
+ /*************************************************************
+ */
+ public ShowDependentableMediatorAction(final ControlFlowDelegationStage stage, final mxGraphComponent graphComponent, final mxCell targetCell) {
+ super(/*propName*/"dependsOnMediator", targetCell, graphComponent);
+ this.stage = stage;
+ }
+
+ /*************************************************************
+ /************************************************************
+ * [ *public ]
+ /*************************************************************
+ * DoM適用可能範囲の表示まで実行する.
+ */
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ showDependentableNodesBySelectedEdge(targetCell);
+ stage.setState(ControlFlowDelegationStageStatus.SHOWING_DEPENDENTABLE_NODES);
+ // ⇒ 以降のDoM実行操作は, 【ControlFlowDelgationCellEditor】で実行される.
+ }
+
+ /*************************************************************
+ /*************************************************************
+ * [ *private ]
+ /*************************************************************
+ * 選択されたセルの, DoM実行な仲介者オブジェクトを表示する.
+ */
+ private void showDependentableNodesBySelectedEdge(Object cellObj) {
+ CallEdgeAttribute callEdgeAttr = (CallEdgeAttribute)graphComponent.getGraph().getModel().getValue(cellObj);
+ if(callEdgeAttr == null) return;
+
+ ControlFlowDelegationStage cfdStage = (ControlFlowDelegationStage)stage;
+ cfdStage.showDependentableNodes(callEdgeAttr);
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ShowFlowLayerWindowAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ShowFlowLayerWindowAction.java
new file mode 100644
index 0000000..1a9e790
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ShowFlowLayerWindowAction.java
@@ -0,0 +1,17 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.ApplicationWindow;
+
+public class ShowFlowLayerWindowAction extends AbstractSystemAction {
+ public ShowFlowLayerWindowAction(ApplicationWindow frame) {
+ super(/*propName*/"showFlowLayer", frame);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ frame.showSwitchLayerWindow();
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ShowNavigationAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ShowNavigationAction.java
new file mode 100644
index 0000000..8d7aacb
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ShowNavigationAction.java
@@ -0,0 +1,19 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.ApplicationWindow;
+
+public class ShowNavigationAction extends AbstractSystemAction {
+
+ public ShowNavigationAction(ApplicationWindow frame) {
+ super(/*propName*/"showNavigation", frame);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ frame.showNavigationWindow();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/TreeLayoutAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/TreeLayoutAction.java
new file mode 100644
index 0000000..a8056eb
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/TreeLayoutAction.java
@@ -0,0 +1,19 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import application.editor.Editor;
+
+public class TreeLayoutAction extends AbstractEditorAction {
+
+ public TreeLayoutAction(Editor editor) {
+ super(/*propName*/"treeLayout", editor);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ editor.setTreeLayout();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ZoomInAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ZoomInAction.java
new file mode 100644
index 0000000..e18fb4f
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ZoomInAction.java
@@ -0,0 +1,29 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.AbstractAction;
+import javax.swing.JOptionPane;
+
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.util.mxResources;
+
+import application.editor.Editor;
+
+public class ZoomInAction extends AbstractViewerAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 6758532166946195926L;
+
+ public ZoomInAction(mxGraphComponent graphComponent) {
+ super(/*propName*/"zoomIn", graphComponent);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ graphComponent.zoomIn();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/actions/ZoomOutAction.java b/AlgebraicDataflowArchitectureModel/src/application/actions/ZoomOutAction.java
new file mode 100644
index 0000000..0e306da
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/actions/ZoomOutAction.java
@@ -0,0 +1,27 @@
+package application.actions;
+
+import java.awt.event.ActionEvent;
+
+import javax.swing.AbstractAction;
+
+import com.mxgraph.swing.mxGraphComponent;
+
+import application.editor.Editor;
+
+public class ZoomOutAction extends AbstractViewerAction {
+ /**
+ *
+ */
+ private static final long serialVersionUID = 8657530769383486605L;
+
+ public ZoomOutAction(mxGraphComponent graphComponent) {
+ super(/*propName*/"zoomOut", graphComponent);
+ }
+
+ @Override
+ public void actionPerformed(ActionEvent e) {
+ super.actionPerformed(e);
+ graphComponent.zoomOut();
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/Editor.java b/AlgebraicDataflowArchitectureModel/src/application/editor/Editor.java
new file mode 100644
index 0000000..82cb881
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/Editor.java
@@ -0,0 +1,529 @@
+package application.editor;
+
+import java.awt.event.MouseListener;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+
+import com.mxgraph.layout.mxCircleLayout;
+import com.mxgraph.layout.mxCompactTreeLayout;
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.util.mxEvent;
+import com.mxgraph.util.mxEventSource.mxIEventListener;
+import com.mxgraph.view.mxCellState;
+import com.mxgraph.view.mxGraph;
+import com.mxgraph.view.mxGraphView;
+
+import application.editor.stages.ControlFlowDelegationStage;
+import application.editor.stages.DataFlowModelingStage;
+import application.editor.stages.PushPullSelectionStage;
+import application.layouts.*;
+import code.ast.CompilationUnit;
+import models.EdgeAttribute;
+import models.controlFlowModel.ControlFlowGraph;
+import models.dataConstraintModel.Channel;
+import models.dataConstraintModel.ResourcePath;
+import models.dataFlowModel.DataTransferModel;
+import models.dataFlowModel.DataTransferChannel;
+import models.dataFlowModel.DataFlowGraph;
+import models.visualModel.FormulaChannel;
+import parser.Parser;
+import parser.exceptions.ExpectedAssignment;
+import parser.exceptions.ExpectedChannel;
+import parser.exceptions.ExpectedChannelName;
+import parser.exceptions.ExpectedColon;
+import parser.exceptions.ExpectedEquals;
+import parser.exceptions.ExpectedFormulaChannel;
+import parser.exceptions.ExpectedGeometry;
+import parser.exceptions.ExpectedInOrOutOrRefKeyword;
+import parser.exceptions.ExpectedIoChannel;
+import parser.exceptions.ExpectedLeftCurlyBracket;
+import parser.exceptions.ExpectedModel;
+import parser.exceptions.ExpectedNode;
+import parser.exceptions.ExpectedRHSExpression;
+import parser.exceptions.ExpectedResource;
+import parser.exceptions.ExpectedRightBracket;
+import parser.exceptions.ExpectedStateTransition;
+import parser.exceptions.WrongJsonExpression;
+import parser.exceptions.WrongLHSExpression;
+import parser.exceptions.WrongRHSExpression;
+import parser.ParserDTRAM;
+
+/**
+ * Main editor for all stages
+ *
+ * @author Nitta
+ *
+ */
+public class Editor {
+ public DataTransferModel model = null;
+ public mxGraph graph = null;
+ private mxGraphComponent graphComponent = null;
+ private mxIEventListener curChangeEventListener = null;
+ private MouseListener curMouseEventListener = null;
+
+ protected Stage curStage = null;
+ protected List stageQueue = null;
+ private List stageChangeListeners = null;
+
+ protected String curFileName = null;
+ protected String curFilePath = null;
+ protected ArrayList codes = null;
+
+ public static DataFlowModelingStage STAGE_DATA_FLOW_MODELING = null;
+ public static PushPullSelectionStage STAGE_PUSH_PULL_SELECTION = null;
+ public static ControlFlowDelegationStage STAGE_CONTROL_FLOW_DELEGATION = null;
+
+ public Editor(mxGraphComponent graphComponent) {
+ this.graphComponent = graphComponent;
+ this.graph = graphComponent.getGraph();
+
+ STAGE_DATA_FLOW_MODELING = new DataFlowModelingStage(graphComponent);
+ STAGE_PUSH_PULL_SELECTION = new PushPullSelectionStage(graphComponent);
+ STAGE_CONTROL_FLOW_DELEGATION = new ControlFlowDelegationStage(graphComponent);
+
+ graphComponent.setCellEditor(STAGE_DATA_FLOW_MODELING.createCellEditor(graphComponent));
+
+ stageQueue = new ArrayList<>();
+ stageQueue.add(STAGE_DATA_FLOW_MODELING);
+ stageQueue.add(STAGE_PUSH_PULL_SELECTION);
+ stageQueue.add(STAGE_CONTROL_FLOW_DELEGATION);
+ curStage = STAGE_DATA_FLOW_MODELING;
+
+ stageChangeListeners = new ArrayList<>();
+ }
+
+ public mxGraph getGraph() {
+ return graph;
+ }
+
+ public mxGraphComponent getGraphComponent() {
+ return this.graphComponent;
+ }
+
+ public DataTransferModel getModel() {
+ model = curStage.getModel();
+ return model;
+ }
+
+ public Stage getCurStage() {
+ return curStage;
+ }
+
+ public boolean canChange(Stage nextStage) {
+ return nextStage.canChangeFrom(curStage);
+ }
+
+ public boolean nextStage() {
+ int curStageNo = stageQueue.indexOf(curStage);
+ if (curStageNo + 1 >= stageQueue.size()) return false;
+ return changeStage(stageQueue.get(curStageNo + 1));
+ }
+
+ public boolean changeStage(Stage nextStage) {
+ if (!nextStage.canChangeFrom(curStage)) return false;
+ nextStage.init(curStage);
+ graphComponent.setCellEditor(nextStage.createCellEditor(graphComponent));
+
+ // add listeners
+ // "curChangeEventListener" will be called when updating the mxGraph.
+ if (curChangeEventListener != null) {
+ graph.getModel().removeListener(curChangeEventListener);
+ }
+ curChangeEventListener = nextStage.createChangeEventListener(this);
+ if (curChangeEventListener != null) {
+ graph.getModel().addListener(mxEvent.CHANGE, curChangeEventListener);
+ }
+
+ // A handler of a mouse event.
+ if(curMouseEventListener != null) {
+ graphComponent.getGraphControl().removeMouseListener(curMouseEventListener);
+ }
+ curMouseEventListener = nextStage.createMouseEventListener(this);
+ if(curMouseEventListener != null) {
+ graphComponent.getGraphControl().addMouseListener(curMouseEventListener);
+ }
+ curStage = nextStage;
+ notifyStageChangeListeners();
+ return true;
+ }
+
+ public void addStageChangeListener(IStageChangeListener stageChangeListener) {
+ stageChangeListeners.add(stageChangeListener);
+ }
+
+ private void notifyStageChangeListeners() {
+ for (IStageChangeListener l: stageChangeListeners) {
+ l.stageChanged(curStage);
+ }
+ }
+
+ public DataFlowGraph getDataFlowGraph() {
+ if (curStage instanceof PushPullSelectionStage) {
+ return ((PushPullSelectionStage) curStage).getDataFlowGraph();
+ } else if (curStage instanceof ControlFlowDelegationStage) {
+ return ((ControlFlowDelegationStage) curStage).getControlFlowGraph().getDataFlowGraph();
+ }
+ return null;
+ }
+
+ public ControlFlowGraph getControlFlowGraph() {
+ if (curStage instanceof ControlFlowDelegationStage) {
+ return ((ControlFlowDelegationStage) curStage).getControlFlowGraph();
+ }
+ return null;
+ }
+
+ public ArrayList getCodes() {
+ return codes;
+ }
+
+ public void setCodes(ArrayList codes) {
+ this.codes = codes;
+ }
+
+ public String getCurFileName() {
+ return curFileName;
+ }
+
+ public String getCurFilePath() {
+ return curFilePath;
+ }
+
+ public void setCurFilePath(String curFilePath) {
+ this.curFilePath = curFilePath;
+ this.curFileName = new File(curFilePath).getName();
+ }
+
+ public void clear() {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return;
+
+ model = null;
+ ((DataFlowModelingStage) curStage).clear();
+
+ curFilePath = null;
+ curFileName = null;
+ codes = null;
+ }
+
+ /**
+ * Open a given file, parse the file, construct a DataFlowModel and a mxGraph
+ * @param file given file
+ * @return a constructed DataFlowModel
+ */
+ public DataTransferModel open(File file) {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return null;
+
+ try {
+ String extension ="";
+ if(file != null && file.exists()) {
+ // get file's name
+ String name = file.getName();
+
+ // get file's extension
+ extension = name.substring(name.lastIndexOf("."));
+ }
+ if(extension.contains(".model")) {
+ openModel(file);
+ } else {
+ // Parse the .dtram file.
+ ParserDTRAM parserDTRAM = new ParserDTRAM(new BufferedReader(new FileReader(file)));
+ try {
+ model = parserDTRAM.doParseModel();
+ if (curStage instanceof DataFlowModelingStage) {
+ // Update the mxGraph.
+ ((DataFlowModelingStage) curStage).setModel(model);
+ }
+ // Restore the geometry.
+ parserDTRAM.doParseGeometry(graph);
+
+ // Change to the push/pull selection stage, analyze the data transfer model and construct a data-flow graph.
+ changeStage(STAGE_PUSH_PULL_SELECTION);
+
+ curFilePath = file.getAbsolutePath();
+ curFileName = file.getName();
+ return model;
+ } catch (ExpectedChannel | ExpectedChannelName | ExpectedLeftCurlyBracket | ExpectedInOrOutOrRefKeyword
+ | ExpectedStateTransition | ExpectedEquals | ExpectedRHSExpression | WrongLHSExpression
+ | WrongRHSExpression | ExpectedRightBracket | ExpectedAssignment | ExpectedModel | ExpectedGeometry | ExpectedNode | ExpectedResource | ExpectedFormulaChannel | ExpectedIoChannel | WrongJsonExpression | ExpectedColon e) {
+ e.printStackTrace();
+ }
+ }
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ }
+
+ return null;
+ }
+
+ public DataTransferModel openModel(File file) {
+ // Force to change to data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+
+ if (!stageChanged) return null;
+
+ try {
+ // Parse the .model file.
+ Parser parser = new Parser(new BufferedReader(new FileReader(file)));
+ try {
+ model = parser.doParse();
+ if (curStage instanceof DataFlowModelingStage) {
+ // Update the mxGraph.
+ ((DataFlowModelingStage) curStage).setModel(model);
+ }
+ // Set DAG layout.
+ setDAGLayout();
+
+ // Change to the push/pull selection stage, analyze the data transfer model and construct a data-flow graph.
+ changeStage(STAGE_PUSH_PULL_SELECTION);
+
+ curFilePath = file.getAbsolutePath();
+ curFileName = file.getName();
+ return model;
+ } catch (ExpectedChannel | ExpectedChannelName | ExpectedLeftCurlyBracket | ExpectedInOrOutOrRefKeyword
+ | ExpectedStateTransition | ExpectedEquals | ExpectedRHSExpression | WrongLHSExpression
+ | WrongRHSExpression | ExpectedRightBracket | ExpectedAssignment | WrongJsonExpression | ExpectedColon e) {
+ e.printStackTrace();
+ }
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ /*************************************************************
+ * [save]
+ /*************************************************************
+ *
+ */
+ public void save() {
+ if (curFilePath != null) {
+ try {
+ File file = new File(curFilePath);
+ String extension = "";
+ if(file != null && file.exists()) {
+ // get a file's name
+ String name = file.getName();
+
+ // get a file's extension
+ extension = name.substring(name.lastIndexOf("."));
+ }
+ if(extension.contains(".model")) {
+ saveModel(file);
+ } else {
+ FileWriter filewriter = new FileWriter(file);
+ filewriter.write(toOutputString());
+ filewriter.close();
+ }
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ public void saveModel(File file) {
+ if (curFilePath != null) {
+ try {
+ FileWriter filewriter = new FileWriter(file);
+ filewriter.write(model.getSourceText());
+ filewriter.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ /**--------------------------------------------------------------------------------
+ * get writing texts "dtram" file information is written.
+ *
+ * @return formatted "dtram" info texts.
+ */
+ protected String toOutputString() {
+ String fileString = "";
+
+ fileString += "model {\n";
+ fileString += this.model.getSourceText();
+ fileString += "}\n";
+
+ fileString += "geometry {\n";
+
+ mxCell root = (mxCell) graph.getDefaultParent();
+ mxCell nodeLayer = (mxCell) root.getChildAt(Stage.NODE_LAYER);
+ mxCell dataFlowLayer = (mxCell) root.getChildAt(Stage.DATA_FLOW_LAYER);
+ for (int i = 0; i < graph.getModel().getChildCount(nodeLayer); i++) {
+ Object cell = graph.getModel().getChildAt(nodeLayer, i);
+ if (graph.getModel().isVertex(cell)) {
+ mxGraphView view = graph.getView();
+ mxCellState state = view.getState(cell);
+ int x = (int) state.getX();
+ int y = (int) state.getY();
+ int w = (int) state.getWidth();
+ int h = (int) state.getHeight();
+
+ for (ResourcePath res: model.getResourcePaths()){
+ if(res instanceof ResourcePath && state.getLabel().equals(res.getResourceName()))
+ fileString += "\tnode r " + state.getLabel() + ":" + x + "," + y + "," + w + "," + h + "\n";
+ }
+
+ for (Channel ioC: model.getIOChannels()) {
+ if(ioC instanceof Channel && state.getLabel().equals(ioC.getChannelName())) {
+ fileString += "\tnode ioc " + state.getLabel() + ":" + x + "," + y + "," + w + "," + h + "\n";
+ }
+ }
+ }
+ }
+ for (int i = 0; i < graph.getModel().getChildCount(dataFlowLayer); i++) {
+ Object cell = graph.getModel().getChildAt(dataFlowLayer, i);
+ if (graph.getModel().isVertex(cell)) {
+ mxGraphView view = graph.getView();
+ mxCellState state = view.getState(cell);
+ int x = (int) state.getX();
+ int y = (int) state.getY();
+ int w = (int) state.getWidth();
+ int h = (int) state.getHeight();
+
+ for(Channel ch: model.getChannels()) {
+ if(ch instanceof FormulaChannel && state.getLabel().equals(ch.getChannelName())) {
+ fileString += "\tnode fc " + state.getLabel() + ":" + x + "," + y + "," + w + "," + h+"\n";
+ } else if(ch instanceof Channel && state.getLabel().equals(ch.getChannelName())) {
+ fileString +="\tnode c " + state.getLabel() + ":" + x + "," + y + "," + w + "," + h+"\n";
+ }
+ }
+ }
+ }
+ fileString += "}\n";
+
+ return fileString;
+ }
+
+ public void setDAGLayout() {
+ mxCell root = (mxCell) graph.getDefaultParent();
+ mxCell dataFlowLayer = (mxCell) root.getChildAt(Stage.DATA_FLOW_LAYER);
+ graph.getModel().beginUpdate();
+ try {
+ DAGLayout ctl = new DAGLayout(graph);
+ ctl.execute(dataFlowLayer);
+// for(int i = 0; i < root.getChildCount(); i++) {
+// ctl.execute(root.getChildAt(i));
+// }
+ } finally {
+ graph.getModel().endUpdate();
+ }
+ }
+
+ public void setTreeLayout() {
+ mxCell root = (mxCell) graph.getDefaultParent();
+ graph.getModel().beginUpdate();
+ try {
+ mxCompactTreeLayout ctl = new mxCompactTreeLayout(graph);
+ ctl.setLevelDistance(100);
+ // ctl.setHorizontal(false);
+ ctl.setEdgeRouting(false);
+ for(int i = 0; i < root.getChildCount(); i++) {
+ ctl.execute(root.getChildAt(i));
+ }
+ } finally {
+ graph.getModel().endUpdate();
+ }
+ }
+
+ public void setCircleLayout() {
+ mxCell root = (mxCell) graph.getDefaultParent();
+ graph.getModel().beginUpdate();
+ try {
+ mxCircleLayout ctl = new mxCircleLayout(graph);
+ for(int i = 0; i < root.getChildCount(); i++) {
+ ctl.execute(root.getChildAt(i));
+ }
+ } finally {
+ graph.getModel().endUpdate();
+ }
+ }
+
+ public void addResourcePath(ResourcePath res) {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return;
+
+ ((DataFlowModelingStage) curStage).addResourcePath(res);
+ model = ((DataFlowModelingStage) curStage).getModel();
+ }
+
+ public void addChannel(DataTransferChannel channel) {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return;
+
+ ((DataFlowModelingStage) curStage).addChannel(channel);
+ model = ((DataFlowModelingStage) curStage).getModel();
+
+ }
+
+ public void addIOChannel(DataTransferChannel ioChannel) {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return;
+
+ ((DataFlowModelingStage) curStage).addIOChannel(ioChannel);
+ model = ((DataFlowModelingStage) curStage).getModel();
+ }
+
+ public void addFormulaChannel(FormulaChannel formulaChannel) {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return;
+
+ ((DataFlowModelingStage) curStage).addFormulaChannel(formulaChannel);
+ model = ((DataFlowModelingStage) curStage).getModel();
+ }
+
+ public boolean connectEdge(mxCell edge, mxCell src, mxCell dst) {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return false;
+
+ boolean isConnected = ((DataFlowModelingStage) curStage).connectEdge(edge, src, dst);
+
+ return isConnected;
+ }
+
+ public void delete() {
+ // Force to change to the data-flow modeling stage.
+ boolean stageChanged = changeStage(STAGE_DATA_FLOW_MODELING);
+ if (!stageChanged) return;
+
+ ((DataFlowModelingStage) curStage).delete();
+ }
+
+ public static class SrcDstAttribute extends EdgeAttribute {
+ private Object src;
+ private Object dst;
+
+ public SrcDstAttribute(Object src, Object dst) {
+ this.src = src;
+ this.dst = dst;
+ }
+
+ public Object getSrouce() {
+ return src;
+ }
+
+ public Object getDestination() {
+ return dst;
+ }
+
+ public String toString() {
+ return "";
+ }
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/FlowCellEditor.java b/AlgebraicDataflowArchitectureModel/src/application/editor/FlowCellEditor.java
new file mode 100644
index 0000000..c44b42d
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/FlowCellEditor.java
@@ -0,0 +1,45 @@
+package application.editor;
+
+import java.util.EventObject;
+
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.swing.view.mxICellEditor;
+
+abstract public class FlowCellEditor implements mxICellEditor {
+
+ protected Stage stage = null;
+ protected mxGraphComponent graphComponent = null;
+
+ protected Object editingCell = null;
+
+ /*************************************************************
+ * [ *constructor]
+ /*************************************************************
+ *
+ * @param stage
+ * @param graphComponent
+ */
+ protected FlowCellEditor(Stage stage, mxGraphComponent graphComponent) {
+ this.stage = stage;
+ this.graphComponent = graphComponent;
+ }
+
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ *
+ */
+ public Object getEditingCell() {
+ return this.editingCell;
+ }
+
+ /*************************************************************
+ *
+ */
+ abstract public void startEditing(Object cellObj, EventObject eventObj);
+
+ /*************************************************************
+ *
+ */
+ abstract public void stopEditing(boolean cancel);
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/IStageChangeListener.java b/AlgebraicDataflowArchitectureModel/src/application/editor/IStageChangeListener.java
new file mode 100644
index 0000000..a345fe2
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/IStageChangeListener.java
@@ -0,0 +1,5 @@
+package application.editor;
+
+public interface IStageChangeListener {
+ public void stageChanged(Stage newStage);
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/InEdgeAttribute.java b/AlgebraicDataflowArchitectureModel/src/application/editor/InEdgeAttribute.java
new file mode 100644
index 0000000..5956f6c
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/InEdgeAttribute.java
@@ -0,0 +1,19 @@
+package application.editor;
+
+import models.dataFlowModel.PushPullAttribute;
+import models.dataFlowModel.PushPullValue;
+import models.dataFlowModel.ResourceNode;
+
+public class InEdgeAttribute extends PushPullAttribute {
+ private ResourceNode srcRes;
+
+ public InEdgeAttribute(PushPullAttribute attr, ResourceNode srcRes) {
+ super();
+ super.setOptions(attr.getOptions());
+ this.srcRes = srcRes;
+ }
+
+ public ResourceNode getSrcResource() {
+ return srcRes;
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/OutEdgeAttribute.java b/AlgebraicDataflowArchitectureModel/src/application/editor/OutEdgeAttribute.java
new file mode 100644
index 0000000..3d5c286
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/OutEdgeAttribute.java
@@ -0,0 +1,18 @@
+package application.editor;
+
+import application.editor.Editor.SrcDstAttribute;
+import models.EdgeAttribute;
+import models.dataFlowModel.ResourceNode;
+
+public class OutEdgeAttribute extends SrcDstAttribute {
+ private ResourceNode dstRes;
+
+ public OutEdgeAttribute(SrcDstAttribute attr, ResourceNode dstRes) {
+ super(attr.getSrouce(), attr.getDestination());
+ this.dstRes = dstRes;
+ }
+
+ public ResourceNode getDstResource() {
+ return dstRes;
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/Stage.java b/AlgebraicDataflowArchitectureModel/src/application/editor/Stage.java
new file mode 100644
index 0000000..ba5baba
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/Stage.java
@@ -0,0 +1,78 @@
+package application.editor;
+
+import java.awt.event.MouseListener;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.swing.view.mxICellEditor;
+import com.mxgraph.util.mxEventSource.mxIEventListener;
+import com.mxgraph.view.mxGraph;
+
+import models.dataFlowModel.DataTransferModel;
+
+abstract public class Stage {
+ protected DataTransferModel model = null;
+ protected mxGraphComponent graphComponent = null;
+ protected mxGraph graph = null;
+ public static final int NODE_LAYER = 0;
+ public static final int DATA_FLOW_LAYER = 0;
+ public static final int PUSH_FLOW_LAYER = 1;
+ public static final int PULL_FLOW_LAYER = 2;
+
+ /*************************************************************
+ * [ *constructor]
+ /*************************************************************
+ *
+ * @param graphComponent
+ */
+ public Stage(mxGraphComponent graphComponent) {
+ this.graphComponent = graphComponent;
+ this.graph = graphComponent.getGraph();
+ }
+
+ /*************************************************************
+ *
+ * @return model
+ */
+ public DataTransferModel getModel() {
+ return model;
+ }
+
+ abstract public boolean canChangeFrom(Stage prevStage);
+ abstract public void init(Stage prevStage);
+ abstract public mxICellEditor createCellEditor(mxGraphComponent graphComponent);
+ abstract public mxIEventListener createChangeEventListener(Editor editor);
+ abstract public MouseListener createMouseEventListener(Editor editor);
+
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ *
+ */
+ public void setEnabledForLayer(final int layerNo, final boolean isEnable) {
+ mxCell rootCell = (mxCell) graph.getDefaultParent();
+ if(rootCell== null) return;
+ if(rootCell.getChildCount() <= 0) return;
+
+ graph.getModel().setVisible(rootCell.getChildAt(layerNo), isEnable);
+ graph.refresh();
+ }
+
+ /*************************************************************
+ * Showing layers are specified number of layers.
+ * @param you want to show numbers of layers.
+ */
+ public void showOnlyLayer(final int... argsOfLayers) {
+ mxCell rootCell = (mxCell) graph.getDefaultParent();
+ if(rootCell== null) return;
+ if(rootCell.getChildCount() <= 0) return;
+
+ for(int i = 0; i < rootCell.getChildCount(); i++) {
+ graph.getModel().setVisible(rootCell.getChildAt(i), false);
+ }
+
+ for(int layerNo : argsOfLayers) {
+ graph.getModel().setVisible(rootCell.getChildAt(layerNo), true);
+ }
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationCellEditor.java b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationCellEditor.java
new file mode 100644
index 0000000..aee891e
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationCellEditor.java
@@ -0,0 +1,188 @@
+package application.editor.stages;
+
+import java.util.EventObject;
+import java.util.logging.Level;
+
+import javax.swing.CellEditor;
+import javax.swing.JOptionPane;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.swing.mxGraphComponent;
+
+import application.ApplicationWindow;
+import application.editor.FlowCellEditor;
+import models.controlFlowModel.CallEdgeAttribute;
+import models.controlFlowModel.EventChannelObjectNode;
+import models.controlFlowModel.ObjectNode;
+import models.controlFlowModel.ObjectNodeAttribute;
+import models.controlFlowModel.StatefulObjectNode;
+
+/*************************************************************
+ *
+ */
+public class ControlFlowDelegationCellEditor extends FlowCellEditor {
+ private mxCell targetEdgeCell = null;
+
+ /*************************************************************
+ * [ *constructor ]
+ /*************************************************************
+ *
+ * @param stage
+ * @param graphComponent
+ */
+ public ControlFlowDelegationCellEditor(ControlFlowDelegationStage stage, mxGraphComponent graphComponent) {
+ super(stage, graphComponent);
+ }
+
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ *
+ */
+ @Override
+ public void startEditing(Object cellObj, EventObject eventObj) {
+ if (editingCell != null) stopEditing(true);
+ ControlFlowDelegationStage cfdStage = (ControlFlowDelegationStage) stage;
+
+ switch (cfdStage.getCurState()) {
+ case SELECTING_AN_EDGE:
+ ApplicationWindow.logger.log(Level.INFO, "Double clicked");
+
+ if (graphComponent.getGraph().getModel().isEdge(cellObj)) {
+
+ targetEdgeCell = (mxCell) cellObj;
+
+ // Logging
+ CallEdgeAttribute callEdgeAttr = (CallEdgeAttribute) graphComponent.getGraph().getModel().getValue(targetEdgeCell);
+ if (callEdgeAttr == null) return;
+
+ String pairNodeStr = "(" + callEdgeAttr.getSourceObjectNode().getName() + ", " + callEdgeAttr.getDestinationObjectNode().getName() + ")" ;
+ ApplicationWindow.logger.log(Level.INFO, "Selecting Control-Flow (src, dst) = " + pairNodeStr);
+
+ showDelegatableNodesBySelectedEdge(cellObj);
+ cfdStage.setState(ControlFlowDelegationStageStatus.SHOWING_DELEGATABLE_NODES);
+ }
+ break;
+
+ case SHOWING_DELEGATABLE_NODES:
+ if (graphComponent.getGraph().getModel().isVertex(cellObj)) {
+ mxCell dstCell = null;
+ if (cellObj instanceof mxCell) dstCell = (mxCell) cellObj;
+ else throw new ClassCastException();
+
+ CallEdgeAttribute callEdgeAttr = (CallEdgeAttribute) graphComponent.getGraph().getModel().getValue(targetEdgeCell);
+ if (callEdgeAttr == null) return;
+
+ ObjectNode dstObjNode = ((ObjectNodeAttribute) dstCell.getValue()).getObjectNode();
+ if (dstObjNode == null) throw new ClassCastException();
+
+ // dstObjNode はCFD適用可能なノードかどうか？
+ if (!cfdStage.isExecutableDelegation(callEdgeAttr, dstObjNode)) {
+ JOptionPane.showMessageDialog(graphComponent, "It's impossible for \"" + dstObjNode.getName() + "\" to delegate.");
+ ApplicationWindow.logger.log(Level.INFO, "\"" + dstObjNode.getName() + "\"" + " wasn't able to apply to CFD");
+ return;
+ }
+
+ // CFD実行 ⇒ 実行後のグラフを表示.
+ cfdStage.showDelegatedGraph(graphComponent.getGraph(), targetEdgeCell, (mxCell) cellObj);
+ ApplicationWindow.logger.log(Level.INFO, "Apply CFD to \"" + dstObjNode.getName() + "\"");
+
+ cfdStage.setState(ControlFlowDelegationStageStatus.SELECTING_AN_EDGE);
+ } else {
+ // Logging
+ ApplicationWindow.logger.log(Level.INFO, "CFD was canceled because it was selected a control-flow");
+
+ cfdStage.resetAllStyleOfCells();
+ cfdStage.setState(ControlFlowDelegationStageStatus.SELECTING_AN_EDGE);
+ }
+ break;
+
+ case SHOWING_DEPENDENTABLE_NODES:
+ if (cfdStage.getCachedCell() == null ) return;
+ this.targetEdgeCell = cfdStage.getCachedCell();
+
+ if (graphComponent.getGraph().getModel().isVertex(cellObj)) {
+ mxCell targetObjCell = null;
+ if (cellObj instanceof mxCell) targetObjCell = (mxCell) cellObj;
+ else throw new ClassCastException();
+
+ ObjectNodeAttribute targetObjNodeAttr = (targetObjCell.getValue() instanceof ObjectNodeAttribute)
+ ?(ObjectNodeAttribute)targetObjCell.getValue()
+ :null;
+ if (targetObjNodeAttr == null) return;
+
+ ObjectNode targetObjNode = targetObjNodeAttr.getObjectNode();
+
+ // 仲介者以外のオブジェクトを選択したときの例外処理
+ if (isNotStatelessObject(targetObjNode)) {
+ JOptionPane.showMessageDialog(graphComponent, "It's impossible for \"" + targetObjNode.getName() + "\" to dependent.");
+ ApplicationWindow.logger.log(Level.INFO, "\"" + targetObjNode.getName() + "\"" + " wasn't able to apply to Depends on Mediator");
+ return;
+ }
+
+ // DoMを実行
+ dependingObjectNode(targetObjCell);
+
+ // Logging
+ ApplicationWindow.logger.log(Level.INFO, "Apply Depedents on Mediator to " + "\"" + targetObjNode.getName() + "\"");
+
+ cfdStage.resetAllStyleOfCells();
+ cfdStage.setState(ControlFlowDelegationStageStatus.SELECTING_AN_EDGE);
+ } else {
+ // Logging
+ ApplicationWindow.logger.log(Level.INFO, "Depends on Mediator was canceled because it was selected a control-flow");
+
+ cfdStage.resetAllStyleOfCells();
+ cfdStage.setState(ControlFlowDelegationStageStatus.SELECTING_AN_EDGE);
+ }
+ break;
+ }
+ }
+
+ /*************************************************************
+ *
+ */
+ @Override
+ public void stopEditing(boolean cancel) {
+ }
+
+ /*************************************************************
+ * [ *private ]
+ /*************************************************************
+ * view
+ **************************************************************
+ * 選択されたエッジが, CFDによって呼び出し元にできるオブジェクトを表示する.
+ * @param cellObj コントロールフローのセル
+ */
+ private void showDelegatableNodesBySelectedEdge(Object cellObj) {
+ CallEdgeAttribute callEdgeAttr = (CallEdgeAttribute) graphComponent.getGraph().getModel().getValue(cellObj);
+ if (callEdgeAttr == null)
+ return;
+
+ ControlFlowDelegationStage cfdStage = (ControlFlowDelegationStage) stage;
+ cfdStage.showDelegatableNodes(callEdgeAttr);
+ }
+
+ /************************************************************
+ * DoMを実行する.
+ * @param targetMediatorCell 選択された仲介者オブジェクト
+ */
+ private void dependingObjectNode(final mxCell targetMediatorCell) {
+ if (targetMediatorCell == null) return;
+
+ ControlFlowDelegationStage cfdStage = (ControlFlowDelegationStage) stage;
+ cfdStage.dependingOnMediatorObject(targetEdgeCell, targetMediatorCell);
+ }
+
+ /************************************************************
+ * あるノードが仲介者（状態を持たない）オブジェクトかどうかを判定する.
+ * @param targetObjNode 選択されたノード
+ */
+ private boolean isNotStatelessObject(final ObjectNode targetObjNode) {
+ if (targetObjNode instanceof StatefulObjectNode) return true;
+ if (targetObjNode instanceof EventChannelObjectNode) return true;
+
+ return false;
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationStage.java b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationStage.java
new file mode 100644
index 0000000..aa60245
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationStage.java
@@ -0,0 +1,825 @@
+package application.editor.stages;
+
+import java.awt.event.MouseEvent;
+import java.awt.event.MouseListener;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Level;
+
+import javax.swing.SwingUtilities;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.model.mxGeometry;
+import com.mxgraph.model.mxGraphModel;
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.swing.util.mxMouseAdapter;
+import com.mxgraph.util.mxEventSource.mxIEventListener;
+import com.mxgraph.util.mxEventObject;
+import com.mxgraph.util.mxPoint;
+import com.mxgraph.view.mxGraph;
+
+import application.ApplicationWindow;
+import application.editor.Editor;
+import application.editor.FlowCellEditor;
+import application.editor.Stage;
+import application.views.PopupMenuBase;
+import application.views.controlFlowDelegation.ControlFlowDelegationStagePopupMenu;
+import models.Edge;
+import models.Node;
+import models.controlFlowModel.CallEdge;
+import models.controlFlowModel.CallEdgeAttribute;
+import models.controlFlowModel.CallGraph;
+import models.controlFlowModel.CompositeCallEdgeAttribute;
+import models.controlFlowModel.ControlFlowDelegator;
+import models.controlFlowModel.ControlFlowGraph;
+import models.controlFlowModel.EventChannelObjectNode;
+import models.controlFlowModel.ObjectNode;
+import models.controlFlowModel.ObjectNodeAttribute;
+import models.controlFlowModel.StatefulObjectNode;
+import models.dataFlowModel.DataFlowGraph;
+import models.dataFlowModel.PushPullValue;
+import models.dataFlowModel.ResourceNode;
+import models.dataFlowModel.ResourceNodeAttribute;
+
+/*************************************************************
+ *
+ */
+public class ControlFlowDelegationStage extends Stage {
+ public final int PORT_DIAMETER = 8;
+ public final int PORT_RADIUS = PORT_DIAMETER / 2;
+
+ private ControlFlowDelegationStageStatus curState = null;
+
+ private ControlFlowGraph controlFlowGraph = null;
+ private PopupMenuBase popupMenu = null;
+
+ private mxCell selectedCellOnAnyEvent = null;
+
+ /*************************************************************
+ * [ *constructor ]
+ /*************************************************************
+ *
+ */
+ public ControlFlowDelegationStage(mxGraphComponent graphComoponent) {
+ super(graphComoponent);
+ this.curState = ControlFlowDelegationStageStatus.SELECTING_AN_EDGE;
+ this.popupMenu = new ControlFlowDelegationStagePopupMenu(this, graphComoponent);
+ }
+
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ * getters / setters
+ /*************************************************************
+ */
+ public ControlFlowGraph getControlFlowGraph() {
+ return controlFlowGraph;
+ }
+
+ /*************************************************************
+ * 今のコントロールフローの操作状態がどうなっているかを取得
+ */
+ public ControlFlowDelegationStageStatus getCurState() {
+ return curState;
+ }
+
+ /*************************************************************
+ * 今のコントロールフローの操作状態をセット.
+ */
+ public void setState(ControlFlowDelegationStageStatus nextState) {
+ curState = nextState;
+ }
+
+
+ /*************************************************************
+ * 「Stage」クラス以外の, 他のクラス上で取得されたセルをセット
+ */
+ public void setCellOnAnyEvent(final mxCell selectedCell) {
+ this.selectedCellOnAnyEvent = selectedCell;
+ }
+
+ /*************************************************************
+ * 「Stage」クラス以外の, 他のクラス上で取得されたセルをget
+ * Action や CellEditor とセルのインスタンス情報を共有するために必要.
+ * (this.seletedCellOnAnyEvent == null) ならグラフ上のどのセルも選択されていないことになる.
+ */
+ public mxCell getCachedCell() {
+ return this.selectedCellOnAnyEvent;
+ }
+
+ /*************************************************************
+ *
+ */
+ @Override
+ public boolean canChangeFrom(Stage prevStage) {
+ if (prevStage instanceof PushPullSelectionStage) return true;
+ return false;
+ }
+
+ /*************************************************************
+ *
+ */
+ @Override
+ public void init(Stage prevStage) {
+ if (prevStage instanceof PushPullSelectionStage) {
+ model = ((PushPullSelectionStage) prevStage).getModel();
+
+ DataFlowGraph dataFlowGraph = ((PushPullSelectionStage) prevStage).getDataFlowGraph();
+
+ controlFlowGraph = new ControlFlowGraph(dataFlowGraph, model);
+
+ clearControlFlowGraphCells(graph);
+ graph = constructGraph(graph, controlFlowGraph);
+ }
+ }
+
+
+ /*************************************************************
+ *
+ */
+ @Override
+ public FlowCellEditor createCellEditor(mxGraphComponent graphComponent) {
+ return new ControlFlowDelegationCellEditor(this, graphComponent);
+ }
+
+ /*************************************************************
+ * ステージ変更時のリスナー作成
+ * @param editor
+ * @return GUI上のイベントリスナー
+ */
+ @Override
+ public mxIEventListener createChangeEventListener(Editor editor) {
+ return new mxIEventListener() {
+ public void invoke(Object sender, mxEventObject evt) {
+ List terminals = new ArrayList<>();
+ mxCell cell = null;
+ for (Object change: ((List) evt.getProperties().get("changes"))) {
+ if (change instanceof mxGraphModel.mxTerminalChange) {
+ mxGraphModel.mxTerminalChange terminalChange = (mxGraphModel.mxTerminalChange) change;
+ cell = (mxCell) terminalChange.getCell();
+ mxCell terminal = (mxCell) terminalChange.getTerminal();
+ terminals.add(terminal);
+ }
+ }
+
+ if (curState != ControlFlowDelegationStageStatus.SELECTING_AN_EDGE) return;
+
+ if (terminals.size() == 2) {
+ graph.removeCells(new mxCell[] {cell});
+ graph.clearSelection();
+ }
+ }
+ };
+ }
+
+ /*************************************************************
+ * ステージ変更時のマウスイベントの発行
+ * @param editor
+ */
+ @Override
+ public MouseListener createMouseEventListener(Editor editor) {
+ MouseListener listener = new mxMouseAdapter() {
+ @Override
+ public void mouseReleased(MouseEvent e) {
+ if (SwingUtilities.isLeftMouseButton(e)) {
+ if (graphComponent.getCellAt(e.getX(), e.getY()) != null) return;
+ if (curState.equals(ControlFlowDelegationStageStatus.SELECTING_AN_EDGE)) return;
+
+ ApplicationWindow.logger.log(Level.INFO, "Reset selection");
+ resetAllStyleOfCells();
+ curState = ControlFlowDelegationStageStatus.SELECTING_AN_EDGE;
+
+ return;
+ }
+ else if (SwingUtilities.isRightMouseButton(e)) {
+ ApplicationWindow.logger.log(Level.INFO, "Open popup menu");
+ popupMenu.show(e.getX(), e.getY());
+ }
+ }
+ };
+ return listener;
+ }
+
+ /*************************************************************
+ * コントロールフローグラフの操作
+ /*************************************************************
+ * CFDが適用できるノードの表示
+ * @param callEdgeAttr 選択された呼び出しエッジの情報
+ */
+ public void showDelegatableNodes(final CallEdgeAttribute callEdgeAttr){
+ mxCell root = (mxCell)graph.getDefaultParent();
+ graph.getModel().beginUpdate();
+ try {
+ ObjectNode delegatingNode = callEdgeAttr.getDestinationObjectNode();
+ for (int layerNo = Stage.PUSH_FLOW_LAYER; layerNo <= PULL_FLOW_LAYER; layerNo++) {
+
+ mxCell layerCell = (mxCell)root.getChildAt(layerNo);
+ for (Object node : graph.getChildVertices(layerCell)) {
+ if ( !(node instanceof mxCell) ) continue;
+ mxCell cell = (mxCell)node;
+
+ ObjectNodeAttribute objNodeAttr = (ObjectNodeAttribute)cell.getValue();
+ if (objNodeAttr == null) return;
+
+ ObjectNode objNode = objNodeAttr.getObjectNode();
+ ControlFlowDelegator delegator = new ControlFlowDelegator(controlFlowGraph);
+ List delegatableNodes = delegator.searchDelegatableNodes(callEdgeAttr.getCallEdge());
+
+ if (delegatableNodes.contains(objNode)) {
+ graph.getModel().setStyle(cell, objNodeAttr.getEnableStyle());
+ }
+ else {
+ graph.getModel().setStyle(cell, objNodeAttr.getDisableStyle());
+ }
+
+ if (delegatingNode.equals(objNodeAttr.getObjectNode()))
+ /* base-Node*/graph.getModel().setStyle(cell, objNodeAttr.getDelegatingStyle());
+ }
+ }
+ }
+ finally {
+ graph.getModel().endUpdate();
+ graph.refresh();
+ }
+ }
+
+ /*************************************************************
+ * DoMを実行可能なノードの表示
+ * @param callEdgeAttr 選択された呼び出しエッジの情報
+ */
+ public void showDependentableNodes(final CallEdgeAttribute callEdgeAttr) {
+ mxCell root = (mxCell)graph.getDefaultParent();
+ mxCell layerCell = (mxCell)root.getChildAt(PULL_FLOW_LAYER);
+ graph.getModel().beginUpdate();
+ try {
+ ObjectNode delegatingNode = callEdgeAttr.getDestinationObjectNode();
+
+ for(Object node : graph.getChildVertices(layerCell)) {
+ if ( !(node instanceof mxCell) ) continue;
+ mxCell cell = (mxCell)node;
+
+ ObjectNodeAttribute objNodeAttr = (ObjectNodeAttribute)cell.getValue();
+ if (objNodeAttr == null) return;
+
+ ObjectNode objNode = objNodeAttr.getObjectNode();
+ ControlFlowDelegator delegator = new ControlFlowDelegator(controlFlowGraph);
+ List delegatableNodes = delegator.searchDependentableMediatorNodes(callEdgeAttr.getCallEdge());
+
+ if (delegatableNodes.contains(objNode)) {
+ graph.getModel().setStyle(cell, objNodeAttr.getEnableStyle());
+ }
+ else {
+ graph.getModel().setStyle(cell, objNodeAttr.getDisableStyle());
+ }
+
+ if (delegatingNode.equals(objNodeAttr.getObjectNode()))
+ /* base-Node*/graph.getModel().setStyle(cell, objNodeAttr.getDelegatingStyle());
+ }
+ }
+ finally {
+ graph.getModel().endUpdate();
+ graph.refresh();
+ }
+ }
+
+ /*************************************************************
+ * CFD実行後のグラフを表示
+ * @param graph 被操作対象のグラフ
+ * @param targetEdgeCell CFD実行時に選択された呼び出しエッジ
+ * @param dstObjNodeCell CFDによって呼び出し元となるセル
+ */
+ public void showDelegatedGraph(mxGraph graph, mxCell targetEdgeCell, final mxCell dstObjNodeCell) {
+ ObjectNode dstObjNode = ((ObjectNodeAttribute)dstObjNodeCell.getValue()).getObjectNode();
+ if (dstObjNode == null) throw new ClassCastException();
+ CallEdgeAttribute targetEdgeAttr = (CallEdgeAttribute)targetEdgeCell.getValue();
+ if (targetEdgeAttr == null) throw new ClassCastException();
+
+ ControlFlowDelegator delegator = new ControlFlowDelegator(controlFlowGraph);
+ delegator.delegateCallEdge(targetEdgeAttr.getCallEdge(), dstObjNode);
+
+ mxCell root = (mxCell) graph.getDefaultParent();
+ mxCell layerCell = null;
+ switch (targetEdgeAttr.getSelectedOption()) {
+ case PUSH:
+ layerCell = (mxCell) root.getChildAt (Stage.PUSH_FLOW_LAYER);
+ break;
+
+ case PULL:
+ case PUSHorPULL:
+ layerCell = (mxCell) root.getChildAt (Stage.PULL_FLOW_LAYER);
+ break;
+ }
+
+ try {
+ mxCell dstNodeCell = targetEdgeAttr.getDestinationCell();
+
+ // 対象となるコントロールフローをグラフ上から削除.
+ if (graph.getModel().getValue(targetEdgeCell) != null) {
+ graph.getModel().remove(targetEdgeCell);
+ }
+
+ CallEdgeAttribute newAttr = new CallEdgeAttribute(targetEdgeAttr.getCallEdge(), targetEdgeAttr.getOriginalSourceObjectNode(),dstObjNodeCell, dstNodeCell);
+ graph.insertEdge(layerCell, "", newAttr, dstObjNodeCell, dstNodeCell, "movable=false;");
+
+ resetAllStyleOfCells();
+ }
+ finally {
+ graph.getModel().endUpdate();
+ }
+ }
+
+ /*************************************************************
+ * 仲介者オブジェクトへの依存（DoM）を実行し, mxGraphを変更する.
+ * @param targetEdgeCell DoMによって変更されるコントロールフローのセル
+ * @param targetMediatorObjNodeCell DoMの対象となる仲介者オブジェクトのセル
+ */
+ public void dependingOnMediatorObject(mxCell targetEdgeCell, mxCell targetMediatorObjNodeCell) {
+ CallEdgeAttribute targetCallEdgeAttr = (CallEdgeAttribute)targetEdgeCell.getValue();
+ if (targetCallEdgeAttr == null) return;
+
+ mxCell root = (mxCell)graph.getDefaultParent();
+ mxCell pullFlowLayerCell = (mxCell)root.getChildAt(Stage.PULL_FLOW_LAYER);
+
+ graph.getModel().beginUpdate();
+
+ try {
+ // 各ノードの情報を取得.
+ ObjectNode srcObjNode = targetCallEdgeAttr.getSourceObjectNode();
+ ObjectNode dstObjNode = targetCallEdgeAttr.getDestinationObjectNode();
+ if (srcObjNode == null || dstObjNode == null) throw new NullPointerException();
+ if ( !(srcObjNode instanceof ObjectNode && dstObjNode instanceof ObjectNode) ) throw new ClassCastException();
+
+ ObjectNodeAttribute targetObjNodeAttr = (ObjectNodeAttribute)targetMediatorObjNodeCell.getValue();
+ if (targetObjNodeAttr == null) throw new NullPointerException();
+
+ ObjectNode targetMediatorObjNode = targetObjNodeAttr.getObjectNode();
+ if (targetMediatorObjNode == null) throw new NullPointerException();
+ if (targetMediatorObjNode instanceof StatefulObjectNode || targetMediatorObjNode instanceof EventChannelObjectNode) return;
+
+ // 新たに接続するエッジ情報を生成.
+ CallEdge srcToMediatorEdge = new CallEdge(targetCallEdgeAttr.getSourceObjectNode(), targetMediatorObjNode, targetCallEdgeAttr.getSelectedOption());
+ CallEdge mediatorToDstEdge = new CallEdge(targetMediatorObjNode, dstObjNode, targetCallEdgeAttr.getSelectedOption());
+ if (srcToMediatorEdge == null || mediatorToDstEdge == null) throw new NullPointerException();
+
+ // ノード同士の接続情報を更新
+ srcObjNode.addOutEdge(srcToMediatorEdge);
+ srcObjNode.removeOutEdge(targetCallEdgeAttr.getCallEdge());
+
+ dstObjNode.removeInEdge(targetCallEdgeAttr.getCallEdge());
+
+ targetMediatorObjNode.addInEdge(srcToMediatorEdge);
+
+ // 既に仲介者に接続されているエッジの情報を CompositeCallEdgeAttr に保持させる.
+ CompositeCallEdgeAttribute compositeEdgeAttr = null;
+
+ for (int i = 0; i < pullFlowLayerCell.getChildCount(); i++) {
+ mxCell edgeCell = (mxCell)pullFlowLayerCell.getChildAt(i);
+ if ( !edgeCell.isEdge() ) continue;
+ if ( !(edgeCell.getValue() instanceof CallEdgeAttribute) ) continue;
+
+ CallEdgeAttribute edgeAttr = (CallEdgeAttribute)edgeCell.getValue();
+
+ if ( !(edgeAttr.getSourceObjectNode().equals(targetMediatorObjNode)) )continue;
+ if ( !(edgeAttr.getDestinationObjectNode().equals(dstObjNode)) )continue;
+
+ compositeEdgeAttr = new CompositeCallEdgeAttribute(edgeAttr);
+
+ break;
+ }
+
+ if (compositeEdgeAttr != null)
+ compositeEdgeAttr.mergeCallEdgeAttribute(targetCallEdgeAttr);
+
+ // mxGraph へ接続状態を反映する.
+ for (int i = 0; i < pullFlowLayerCell.getChildCount(); i++) {
+ mxCell nodeCell = (mxCell)pullFlowLayerCell.getChildAt(i);
+ if ( !nodeCell.isVertex() ) continue;
+
+ ObjectNodeAttribute cellObjNodeAttr = (ObjectNodeAttribute)nodeCell.getValue();
+ if (cellObjNodeAttr == null) throw new ClassCastException("dosen't have the value of ");
+
+ // nodeCell が呼び出し元のノードか？
+ if (nodeCell.equals(targetCallEdgeAttr.getSourceCell())){
+ mxCell srcNodeCell = targetCallEdgeAttr.getSourceCell();
+
+ // mxGraph に変更対象のコントロールフローが存在するなら削除する.
+ if (graph.getModel().getValue(targetEdgeCell) != null)
+ graph.getModel().remove(targetEdgeCell);
+
+ graph.insertEdge(pullFlowLayerCell, null, compositeEdgeAttr, srcNodeCell, targetMediatorObjNodeCell, "movable=false;");
+ continue;
+ }
+
+ }
+ }
+ finally {
+ graph.getModel().endUpdate();
+ }
+ }
+
+ /*************************************************************
+ * グラフの選択状態をクリアする.
+ */
+ public void resetAllStyleOfCells() {
+ mxCell root = (mxCell)graph.getDefaultParent();
+
+ graph.getModel().beginUpdate();
+ try {
+ for (int layerNo = Stage.PUSH_FLOW_LAYER; layerNo <= Stage.PULL_FLOW_LAYER; layerNo++) {
+
+ mxCell layerCell = (mxCell)root.getChildAt(layerNo);
+ for (Object node : graph.getChildVertices(layerCell)) {
+ mxCell cell = null;
+ if (node instanceof mxCell) cell = (mxCell)node;
+ else continue;
+
+ ObjectNodeAttribute objNodeAttr = (ObjectNodeAttribute)(cell.getValue());
+ if (objNodeAttr == null) throw new NullPointerException("");
+
+ graph.getModel().setStyle(cell, objNodeAttr.getDefaultStyle());
+ }
+ }
+ }
+ finally {
+ graph.getModel().endUpdate();
+ graph.refresh();
+ }
+ }
+
+ /*************************************************************
+ * コントロールフローに対して, 状態を持たないノードを挿入する.
+ * @param targetEdge CFDによって変更されるコントロールフロー.
+ * @param insertObjName 挿入するノードの名前
+ */
+ public void insertObjectNodeCellInControlFlowLayer(mxCell targetEdge, final String insertObjName) {
+ CallEdgeAttribute callEdgeAttr = (CallEdgeAttribute)targetEdge.getValue();
+ if (callEdgeAttr == null) throw new NullPointerException();
+
+ mxCell root = (mxCell)graph.getDefaultParent();
+ mxCell layerCell = null;
+ switch(callEdgeAttr.getSelectedOption()) {
+ case PUSH:
+ layerCell = (mxCell)root.getChildAt(Stage.PUSH_FLOW_LAYER);
+ break;
+
+ case PULL:
+ case PUSHorPULL:
+ layerCell = (mxCell)root.getChildAt(Stage.PULL_FLOW_LAYER);
+ break;
+ }
+
+ graph.getModel().beginUpdate();
+
+ try {
+ // オブジェクトは ObjectNode として挿入する.
+ ObjectNode insertObjNode = new ObjectNode(insertObjName);
+ ObjectNodeAttribute objNodeAttr = new ObjectNodeAttribute(insertObjNode);
+
+ mxPoint srcPoint = new mxPoint(callEdgeAttr.getSourceCell().getGeometry().getX(), callEdgeAttr.getSourceCell().getGeometry().getY());
+ mxPoint dstPoint = new mxPoint(callEdgeAttr.getDestinationCell().getGeometry().getX(), callEdgeAttr.getDestinationCell().getGeometry().getY());
+ mxPoint insertPoint = new mxPoint(
+ (srcPoint.getX() + dstPoint.getX())/2,
+ (srcPoint.getY() + dstPoint.getY())/2);
+
+ mxCell insertObjNodeCell =
+ (mxCell)graph.insertVertex(layerCell, null, objNodeAttr,
+ /* 座標 */ insertPoint.getX(), insertPoint.getY(),
+ /* スケール*/ 40, 40,
+ objNodeAttr.getDefaultStyle());
+ insertObjNodeCell.setValue(objNodeAttr);
+
+ addObjectNodeToCallGraph(insertObjNode, callEdgeAttr.getSelectedOption());
+
+ ObjectNode srcObjNode = callEdgeAttr.getSourceObjectNode();
+ ObjectNode dstObjNode = callEdgeAttr.getDestinationObjectNode();
+ if (srcObjNode == null || dstObjNode == null) throw new NullPointerException();
+ if ( !(srcObjNode instanceof ObjectNode && dstObjNode instanceof ObjectNode) ) throw new ClassCastException();
+
+ CallEdge srcToInsertEdge = callEdgeAttr.getCallEdge();
+ CallEdge insertToDstEdge = new CallEdge(insertObjNode, dstObjNode, callEdgeAttr.getSelectedOption());
+ if (srcToInsertEdge == null || insertToDstEdge == null) throw new NullPointerException();
+
+ // ノードとエッジを再接続する
+ dstObjNode.removeInEdge(srcToInsertEdge);
+ dstObjNode.addInEdge(insertToDstEdge);
+
+ srcToInsertEdge.setDestination(insertObjNode); // 呼び出し先オブジェクトを変更する.
+
+ insertObjNode.addInEdge(srcToInsertEdge);
+ insertObjNode.addOutEdge(insertToDstEdge);
+
+ // mxGraphを更新する.
+ for(int i =0; i < layerCell.getChildCount(); i++) {
+ mxCell nodeCell = (mxCell)layerCell.getChildAt(i);
+ if (!nodeCell.isVertex()) continue;
+
+ ObjectNodeAttribute cellObjNodeAttr = (ObjectNodeAttribute)nodeCell.getValue();
+ if (cellObjNodeAttr == null) throw new ClassCastException("dosen't have the value of ");
+
+ // nodeCell が呼び出し元のオブジェクトか？
+ if (nodeCell.equals(callEdgeAttr.getSourceCell())){
+ mxCell srcNodeCell = callEdgeAttr.getSourceCell();
+ CallEdgeAttribute newInEdgeAttr = new CallEdgeAttribute(srcToInsertEdge, srcNodeCell, insertObjNodeCell);
+
+ // mxGraph上にtargetEdgeが残っているなら削除する.
+ if (graph.getModel().getValue(targetEdge) != null)
+ graph.getModel().remove(targetEdge);
+
+ mxCell outPortCell = (mxCell)srcNodeCell.getChildAt(0);
+ if
+ (outPortCell != null) {
+ graph.insertEdge(layerCell, null, newInEdgeAttr, outPortCell, insertObjNodeCell, "movable=false;");
+ }
+ else {
+ graph.insertEdge(layerCell, null, newInEdgeAttr, srcNodeCell, insertObjNodeCell, "movable=false;");
+ }
+ continue;
+ }
+ // nodeCell は呼び出し先オブジェクトか？
+ else if (nodeCell.equals(callEdgeAttr.getDestinationCell())) {
+ mxCell dstNodeCell = callEdgeAttr.getDestinationCell();
+ CallEdgeAttribute newOutEdgeAttr = new CallEdgeAttribute(insertToDstEdge, insertObjNodeCell, dstNodeCell);
+
+ // mxGraph上にtargetEdgeが残っているなら削除する.
+ if (graph.getModel().getValue(targetEdge) != null)
+ graph.getModel().remove(targetEdge);
+
+ graph.insertEdge(layerCell, null, newOutEdgeAttr, insertObjNodeCell, dstNodeCell, "movable=false;");
+
+ continue;
+ }
+ }
+ }
+ finally {
+ graph.getModel().endUpdate();
+ }
+ }
+
+ /*************************************************************
+ * CFD適用可能かどうかを判定する
+ * @param targetEdgeAttr CFDによって呼び出し元が変更されるコントロールフロー
+ * @param dstObjNode CFDによって呼び出し元となるオブジェクト
+ */
+ public boolean isExecutableDelegation(final CallEdgeAttribute targetEdgeAttr, final ObjectNode dstObjNode) {
+ ControlFlowDelegator delegator = new ControlFlowDelegator(controlFlowGraph);
+ List delegatableNodes = delegator.searchDelegatableNodes(targetEdgeAttr.getCallEdge());
+
+ return delegatableNodes.contains(dstObjNode);
+ }
+
+ /*************************************************************
+ /*************************************************************
+ * [ *private ]
+ /*************************************************************
+ * GUI上のグラフを生成する
+ * @param graph 初期化対象のグラフ
+ * @param controlFlowGraph
+ */
+ private mxGraph constructGraph(mxGraph graph, ControlFlowGraph controlFlowGraph) {
+ showOnlyLayer(PUSH_FLOW_LAYER, PULL_FLOW_LAYER);
+
+ graph.getModel().beginUpdate();
+ try {
+ // PUSH/PULLごとに ResourceNode, mxCellのインスタンスを対応させる.
+ Map pushResNodeCells = createCellsOfResourceMap(PUSH_FLOW_LAYER);
+ Map pullResNodeCells = createCellsOfResourceMap(PULL_FLOW_LAYER);
+
+ Map pushFlowEventNodeCells = createEventChannelCells(PUSH_FLOW_LAYER);
+
+ // PUSH/PULLのmxGraph上の頂点をエッジでつなぐ.
+ graph = insertControlFlowEdges(PUSH_FLOW_LAYER, pushResNodeCells, pushFlowEventNodeCells);
+ graph = insertControlFlowEdges(PULL_FLOW_LAYER, pullResNodeCells, null);
+
+ } finally {
+ graph.getModel().endUpdate();
+ }
+ return graph;
+ }
+
+
+ /*************************************************************
+ * データフローモデリングステージへ戻るとき, GUI上のコントローフローグラフを削除する.
+ * @param graph 変更対象のグラフ
+ */
+ private void clearControlFlowGraphCells(mxGraph graph) {
+ mxCell root = (mxCell) graph.getDefaultParent();
+
+ graph.getModel().beginUpdate();
+ try {
+ // Rootのレイヤー以下のPUSH/PULLレイヤーを削除.
+ root.remove (root.getChildAt(PULL_FLOW_LAYER));
+ root.remove (root.getChildAt(PUSH_FLOW_LAYER));
+
+ root.insert (new mxCell());
+ root.insert (new mxCell());
+ } finally {
+ graph.getModel().endUpdate();
+ graph.refresh();
+ }
+ }
+
+
+ /*************************************************************
+ * mxGraphの指定したレイヤー上にリソースのノードを追加する.
+ * また, mxGraph上のセルにリソースの情報をマッピングする.
+ * @param layerNumber mxCellを追加する, PUSH/PULLのレイヤー番号
+ * @return ノード（リソース）の情報と, 対応するセルのインスタンスのマップ
+ */
+ private Map createCellsOfResourceMap(final int layerNumber) {
+ Map resNodeCells = new HashMap<>();
+
+ mxCell root = (mxCell)graph.getDefaultParent();
+ mxCell nodeLayerCell = (mxCell)root.getChildAt(NODE_LAYER);
+ mxCell layerCell = (mxCell)root.getChildAt(layerNumber);
+
+ // データフローグラフ上に存在するリソースの情報をコントロールフローグラフに引き継ぐ.
+ for (ResourceNode resNode : controlFlowGraph.getDataFlowGraph().getResouceNodes()) {
+
+ // 「リソース」に対応するノードのインスタンスを生成.
+ ObjectNode objNode = null;
+ switch (layerNumber) {
+ case PUSH_FLOW_LAYER:
+ if (controlFlowGraph.getPushCallGraph().getStatefulObjectNode(resNode) != null)
+ objNode = controlFlowGraph.getPushCallGraph().getStatefulObjectNode(resNode);
+ break;
+
+ case PULL_FLOW_LAYER:
+ if (controlFlowGraph.getPullCallGraph().getStatefulObjectNode(resNode) != null)
+ objNode = controlFlowGraph.getPullCallGraph().getStatefulObjectNode(resNode);
+ break;
+ }
+
+ if (objNode == null) continue;
+
+ for(int i =0; i < nodeLayerCell.getChildCount(); i++) {
+ mxCell nodeCell = (mxCell)nodeLayerCell.getChildAt(i);
+ if( nodeCell.getValue() instanceof ResourceNodeAttribute ) {
+ nodeCell = (mxCell)nodeLayerCell.getChildAt(i);
+ }
+ else continue;
+
+ // ！不要かもしれない！
+ // ResourceNodeがちゃんとAttributeを持っているかをチェックして, 不正値検出しようとしてるみたい.
+ ResourceNodeAttribute resNodeAttr = (ResourceNodeAttribute) nodeCell.getValue();
+ if (!resNodeAttr.getResourceNode().equals(resNode) ) continue;
+
+ // ノードの情報をmxCellにマッピング.
+ ObjectNodeAttribute objNodeAttr = new ObjectNodeAttribute(objNode);
+
+ mxCell resNodeObjCell = (mxCell)graph.insertVertex (layerCell, null, objNodeAttr,
+ /* サイズ */nodeCell.getGeometry().getX(), nodeCell.getGeometry().getY(),
+ /* 座標 */nodeCell.getGeometry().getWidth(), nodeCell.getGeometry().getHeight(),
+ objNodeAttr.getDefaultStyle());
+
+ resNodeCells.put(resNode, resNodeObjCell);
+ }
+ }
+
+ return resNodeCells;
+ }
+
+
+ /*************************************************************
+ * mxGraphの指定したレイヤー上にイベントチャンネルのノードを追加する.
+ * また, mxGraph上のセルにイベントチャンネルの情報をマッピングする.
+ * @param layerNumber 指定したレイヤー（現状PULLは例外扱いしている）
+ * @return イベントチャンネルの情報と, 対応するセルのインスタンスのマップ
+ */
+ private Map createEventChannelCells(final int layerNumber){
+ if (layerNumber == PULL_FLOW_LAYER) return null;
+
+ mxCell root = (mxCell)graph.getDefaultParent();
+ mxCell layerCell = (mxCell)root.getChildAt(layerNumber);
+
+ Map eventChannelCells = new HashMap<>();
+
+ graph.getModel().beginUpdate();
+ try {
+ mxGeometry outPortGeometry = new mxGeometry (1.0, 0.5, PORT_DIAMETER, PORT_DIAMETER);
+ outPortGeometry.setOffset (new mxPoint(-PORT_RADIUS, -PORT_RADIUS));
+ outPortGeometry.setRelative (true);
+
+ CallGraph callGraph = controlFlowGraph.getPushCallGraph();
+
+ // イベントチャンネルのセルを追加
+ for (Node node : callGraph.getNodes()) {
+ EventChannelObjectNode entryPointObjNode = null;
+ if (node instanceof EventChannelObjectNode)
+ entryPointObjNode = (EventChannelObjectNode) node;
+ else continue;
+
+ ObjectNodeAttribute entryObjAttr = new ObjectNodeAttribute(entryPointObjNode);
+
+ // イベントチャンネルの名前と座標値をデータフローグラフから取得.
+ mxCell dataFlowLayerCell = (mxCell)root.getChildAt(Stage.DATA_FLOW_LAYER);
+ for (int i = 0; i < dataFlowLayerCell.getChildCount(); i++) {
+ mxCell channelCell =(mxCell)dataFlowLayerCell.getChildAt(i);
+
+ String eventChObjNodeName = entryPointObjNode.getIOChannel().getChannelName();
+ String channelCellName = "";
+ if (channelCell.getValue() instanceof String) channelCellName = (String) channelCell.getValue();
+ else continue;
+
+ if (!eventChObjNodeName.equals(channelCellName)) continue;
+
+ mxCell entryPointCelll = (mxCell) graph.insertVertex (layerCell, null, entryObjAttr,
+ /* スケール */ channelCell.getGeometry().getX(), channelCell.getGeometry().getY(),
+ /* 座標 */ channelCell.getGeometry().getWidth(), channelCell.getGeometry().getHeight());
+ mxCell port_out = new mxCell (null, outPortGeometry, "shape=ellipse;perimter=ellipsePerimeter");
+ port_out.setVertex (true);
+
+ graph.addCell (port_out, entryPointCelll);
+ eventChannelCells.put (entryPointObjNode, entryPointCelll);
+ }
+ }
+ }
+ finally {
+ graph.getModel().endUpdate();
+ }
+
+ return eventChannelCells;
+ }
+
+
+ /*************************************************************
+ * コントロールフローグラフの各頂点セルの間に, エッジのセルを追加する.
+ * @param layerNumber エッジを追加したいmxGraphのレイヤー
+ * @param resNodeCells リソースと, その頂点セルのインスタンスのマップ
+ * @param eventChNodeCells イベントチャンネルと, その頂点セルのインスタンスのマップ
+ */
+ private mxGraph insertControlFlowEdges(final int layerNumber,
+ final Map resNodeCells, final Map eventChNodeCells) {
+ mxCell root = (mxCell)graph.getDefaultParent();
+ mxCell layerCell = (mxCell)root.getChildAt(layerNumber);
+
+ CallGraph callGraph = (layerNumber == PUSH_FLOW_LAYER)
+ ? controlFlowGraph.getPushCallGraph()
+ : controlFlowGraph.getPullCallGraph();
+
+ for (Edge callGraphEdge : callGraph.getEdges()) {
+ if ( !(callGraphEdge instanceof CallEdge))continue;
+ CallEdge callEdge = (CallEdge) callGraphEdge;
+
+ // エッジがノードと接続しているか？
+ if (callEdge.getSource() == null || callEdge.getDestination() == null) continue;
+
+ Node srcResNode = null;
+ ResourceNode dstResNode = ((StatefulObjectNode)callEdge.getDestination()).getResource();
+
+ mxCell srcNodeCell =null;
+ mxCell srcOutPortCell = null;
+ mxCell dstNodeCell = resNodeCells.get(dstResNode);
+
+ if (callEdge.getSource() instanceof StatefulObjectNode) {
+ srcResNode = ((StatefulObjectNode)callEdge.getSource()).getResource();
+ srcNodeCell =resNodeCells.get(srcResNode);
+ }
+ else if (callEdge.getSource() instanceof EventChannelObjectNode) {
+ srcResNode = (EventChannelObjectNode)callEdge.getSource();
+ srcNodeCell = eventChNodeCells.get(srcResNode);
+ srcOutPortCell = (mxCell)srcNodeCell.getChildAt(0);
+ }
+ else continue;
+
+ if(srcNodeCell == null || dstNodeCell == null) continue;
+
+ CallEdgeAttribute callEdgeAttr = new CallEdgeAttribute(callEdge, (ObjectNode)callEdge.getSource(), srcNodeCell, dstNodeCell);
+
+ if (srcResNode instanceof ResourceNode) {
+ graph.insertEdge(layerCell, null, callEdgeAttr, srcNodeCell, dstNodeCell, "movable=false;");
+ }
+ // イベントチャンネルはoutPortのセルの座標を参照.
+ else if (srcResNode instanceof EventChannelObjectNode) {
+ graph.insertEdge(layerCell, null, callEdgeAttr, srcOutPortCell, dstNodeCell, "movable=false;");
+ }
+
+ }
+ return graph;
+ }
+
+
+ /*************************************************************
+ * 状態を持たないオブジェクトをコントロールフローグラフに追加する.
+ * @param insertObjNode 追加したいオブジェクトの情報
+ * @param selectedOption コントロールフローのデータ転送方式
+ */
+ private void addObjectNodeToCallGraph(final ObjectNode insertObjNode, final PushPullValue selectedOption) {
+ switch (selectedOption) {
+ case PUSH:
+ if (controlFlowGraph.getPushCallGraph().getNodes().contains(insertObjNode)) return;
+ controlFlowGraph.getPushCallGraph().addNode(insertObjNode);
+
+ break;
+
+ case PULL:
+ case PUSHorPULL:
+ if (controlFlowGraph.getPullCallGraph().getNodes().contains(insertObjNode)) return;
+ controlFlowGraph.getPullCallGraph().addNode(insertObjNode);
+
+ break;
+ }
+ }
+
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationStageStatus.java b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationStageStatus.java
new file mode 100644
index 0000000..9e7ddb2
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/ControlFlowDelegationStageStatus.java
@@ -0,0 +1,10 @@
+package application.editor.stages;
+
+/*************************************************************
+ *
+ */
+public enum ControlFlowDelegationStageStatus {
+ SELECTING_AN_EDGE, // いずれかのエッジを選ぼうとしている状態（Idle状態）
+ SHOWING_DELEGATABLE_NODES, // CFD適用可能範囲を表示している状態
+ SHOWING_DEPENDENTABLE_NODES // DoM適用可能範囲を表示している状態
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/stages/DataFlowCellEditor.java b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/DataFlowCellEditor.java
new file mode 100644
index 0000000..a893a85
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/DataFlowCellEditor.java
@@ -0,0 +1,152 @@
+package application.editor.stages;
+
+import java.awt.GridBagConstraints;
+import java.awt.GridBagLayout;
+import java.awt.Rectangle;
+import java.util.EventObject;
+import java.util.List;
+
+import javax.swing.BorderFactory;
+import javax.swing.JComboBox;
+import javax.swing.JLabel;
+import javax.swing.JOptionPane;
+import javax.swing.JPanel;
+import javax.swing.JTextArea;
+import javax.swing.JTextField;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.model.mxIGraphModel;
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.swing.view.mxICellEditor;
+import com.mxgraph.util.mxConstants;
+import com.mxgraph.util.mxUtils;
+import com.mxgraph.view.mxCellState;
+
+import application.editor.Editor;
+import application.editor.FlowCellEditor;
+import models.algebra.Expression;
+import models.dataFlowModel.DataTransferModel;
+import models.dataFlowModel.DataTransferChannel;
+import models.dataFlowModel.PushPullAttribute;
+import models.dataFlowModel.PushPullValue;
+import models.visualModel.FormulaChannel;
+import parser.Parser;
+import parser.Parser.TokenStream;
+import parser.exceptions.ExpectedColon;
+import parser.exceptions.ExpectedRightBracket;
+import parser.exceptions.WrongJsonExpression;
+
+/*************************************************************
+ *
+ */
+public class DataFlowCellEditor extends FlowCellEditor {
+
+ /*************************************************************
+ * [ *constructor ]
+ /*************************************************************
+ *
+ * @param stage
+ * @param graphComponent
+ */
+ public DataFlowCellEditor(DataFlowModelingStage stage, mxGraphComponent graphComponent) {
+ super(stage, graphComponent);
+ }
+
+ /*************************************************************
+ *
+ * @param cellObj
+ * @param eventObj
+ */
+ @Override
+ public void startEditing(Object cellObj, EventObject eventObj) {
+ if (editingCell != null) {
+ stopEditing(true);
+ }
+
+ if (!graphComponent.getGraph().getModel().isEdge(cellObj)) {
+ DataTransferChannel ch = (DataTransferChannel) stage.getModel().getChannel((String) ((mxCell) cellObj).getValue());
+ if (ch == null) {
+ ch = (DataTransferChannel) stage.getModel().getIOChannel((String) ((mxCell) cellObj).getValue());
+ if(ch == null) {
+ //resource
+ return;
+ }
+ }
+
+ if (ch instanceof FormulaChannel) {
+
+ JPanel panel = new JPanel();
+ JLabel label1 = new JLabel("Formula: ");
+ JLabel label2 = new JLabel("Source: ");
+ GridBagLayout layout = new GridBagLayout();
+ panel.setLayout(layout);
+ GridBagConstraints gbc = new GridBagConstraints();
+
+ gbc.gridx = 0;
+ gbc.gridy = 0;
+ layout.setConstraints(label1, gbc);
+ panel.add(label1);
+
+ gbc.gridx = 1;
+ gbc.gridy = 0;
+ JTextField formulaText = new JTextField(((FormulaChannel) ch).getFormula(),15);
+ layout.setConstraints(formulaText, gbc);
+ panel.add(formulaText);
+
+ gbc.gridx = 0;
+ gbc.gridy = 1;
+ layout.setConstraints(label2, gbc);
+ panel.add(label2);
+
+ gbc.gridx = 1;
+ gbc.gridy = 1;
+ JTextArea textArea = new JTextArea(ch.getSourceText(),7,15);
+ textArea.setEditable(false);
+ layout.setConstraints(textArea, gbc);
+ panel.add(textArea);
+
+ int r = JOptionPane.showConfirmDialog(
+ null, // owner window
+ panel, // message
+ "Edit Formula Channel", // window's title
+ JOptionPane.OK_CANCEL_OPTION, // option (button types)
+ JOptionPane.QUESTION_MESSAGE); // message type (icon types)
+ if (r == JOptionPane.OK_OPTION) {
+ TokenStream stream = new Parser.TokenStream();
+ Parser parser = new Parser(stream);
+
+ String formula = formulaText.getText();
+ stream.addLine(formula.split(Parser.EQUALS)[1]);
+
+
+ try {
+ Expression exp = parser.parseTerm(stream, stage.getModel());
+ ((FormulaChannel) ch).setFormula(formula);
+ ((FormulaChannel) ch).setFormulaTerm(exp);
+ } catch (ExpectedRightBracket | WrongJsonExpression | ExpectedColon e) {
+ e.printStackTrace();
+ }
+ }
+ } else {
+ JPanel panel = new JPanel();
+ JTextArea textArea = new JTextArea(ch.getSourceText(), 10, 20);
+ panel.add(textArea);
+ // JEditorPane panel = new JEditorPane("text/plain", ch.toString());
+ // panel.setEditable(true);
+ int ret = JOptionPane.showConfirmDialog(null, panel, "Channel Code", JOptionPane.OK_CANCEL_OPTION);
+ if (ret == JOptionPane.OK_OPTION) {
+ ((DataFlowModelingStage)stage).setChannelCode(ch, textArea.getText());
+ }
+ }
+ return;
+ }
+ }
+
+ /*************************************************************
+ *
+ * @param cancel
+ */
+ @Override
+ public void stopEditing(boolean cancel) {
+ }
+}
diff --git a/AlgebraicDataflowArchitectureModel/src/application/editor/stages/DataFlowModelingStage.java b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/DataFlowModelingStage.java
new file mode 100644
index 0000000..8db3522
--- /dev/null
+++ b/AlgebraicDataflowArchitectureModel/src/application/editor/stages/DataFlowModelingStage.java
@@ -0,0 +1,467 @@
+package application.editor.stages;
+
+import java.awt.event.MouseListener;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import com.mxgraph.model.mxCell;
+import com.mxgraph.model.mxGeometry;
+import com.mxgraph.model.mxGraphModel;
+import com.mxgraph.swing.mxGraphComponent;
+import com.mxgraph.util.mxEventSource.mxIEventListener;
+import com.mxgraph.util.mxEventObject;
+import com.mxgraph.util.mxPoint;
+import com.mxgraph.view.mxGraph;
+
+import algorithms.Validation;
+import application.editor.Editor;
+import application.editor.Editor.SrcDstAttribute;
+import application.editor.FlowCellEditor;
+import application.editor.Stage;
+import models.dataConstraintModel.Channel;
+import models.dataConstraintModel.ChannelMember;
+import models.dataConstraintModel.ResourcePath;
+import models.dataFlowModel.DataTransferChannel;
+import models.dataFlowModel.DataTransferModel;
+import models.dataFlowModel.ResourceNodeAttribute;
+import models.visualModel.FormulaChannel;
+import parser.Parser;
+import parser.Parser.TokenStream;
+import parser.exceptions.ExpectedAssignment;
+import parser.exceptions.ExpectedChannel;
+import parser.exceptions.ExpectedChannelName;
+import parser.exceptions.ExpectedColon;
+import parser.exceptions.ExpectedEquals;
+import parser.exceptions.ExpectedInOrOutOrRefKeyword;
+import parser.exceptions.ExpectedLeftCurlyBracket;
+import parser.exceptions.ExpectedRHSExpression;
+import parser.exceptions.ExpectedRightBracket;
+import parser.exceptions.ExpectedStateTransition;
+import parser.exceptions.WrongJsonExpression;
+import parser.exceptions.WrongLHSExpression;
+import parser.exceptions.WrongRHSExpression;
+
+/*************************************************************
+ *
+ * Issue : リソースからチャンネルに対して, 新たにエッジを引こうとするとキャンセルされる.
+ */
+public class DataFlowModelingStage extends Stage {
+ public int PORT_DIAMETER = 8;
+ public int PORT_RADIUS = PORT_DIAMETER / 2;
+
+ private boolean bReflectingArchitectureModel = false;
+
+ /*************************************************************
+ * [ *constructor]
+ /*************************************************************
+ *
+ */
+ public DataFlowModelingStage(mxGraphComponent graphComponent) {
+ super(graphComponent);
+ }
+
+ /*************************************************************
+ * [ *public ]
+ /*************************************************************
+ *
+ */
+ @Override
+ public boolean canChangeFrom(Stage prevStage) {
+ return true;
+ }
+
+ /*************************************************************
+ *
+ */
+ @Override
+ public void init(Stage prevStage) {
+ showOnlyLayer(DATA_FLOW_LAYER);
+ }
+
+ /*************************************************************
+ *
+ */
+ @Override
+ public FlowCellEditor createCellEditor(mxGraphComponent graphComponent) {
+ return new DataFlowCellEditor(this, graphComponent);
+ }
+
+ @Override
+ public mxIEventListener createChangeEventListener(Editor editor) {
+ return new mxIEventListener() {
+ public void invoke(Object sender, mxEventObject evt) {
+ List terminals = new ArrayList<>();
+ mxCell cell = null;
+ for (Object change: ((List) evt.getProperties().get("changes"))) {
+ if (change instanceof mxGraphModel.mxTerminalChange) {
+ mxGraphModel.mxTerminalChange terminalChange = (mxGraphModel.mxTerminalChange) change;
+ cell = (mxCell) terminalChange.getCell();
+ mxCell terminal = (mxCell) terminalChange.getTerminal();
+ terminals.add(terminal);
+ }
+ }
+ if (terminals.size() == 2) {
+ if (!editor.connectEdge(cell, terminals.get(0), terminals.get(1))) {
+ graph.removeCells(new mxCell[] {cell});
+ graph.clearSelection();
+ }
+ }
+ }
+ };
+ }
+
+ @Override
+ public MouseListener createMouseEventListener(Editor editor) {
+ return null;
+ }
+
+ /*************************************************************
+ * mxGraphのレイヤーを全てクリアする.
+ */
+ public void clear() {
+ model = null;
+ ((mxGraphModel) graph.getModel()).clear();
+
+ // 空のレイヤーを新規作成
+ mxCell root = (mxCell) graph.getDefaultParent();
+ graph.getModel().beginUpdate();
+ try {
+ root.insert(new mxCell()); // NODE_LAYER, DATA_FLOW_LAYER
+ root.insert(new mxCell()); // PUSH_FLOW_LAYER
+ root.insert(new mxCell()); // PULL_FLOW_LAYER
+
+ showOnlyLayer(NODE_LAYER, DATA_FLOW_LAYER);
+ }
+ finally {
+ graph.getModel().endUpdate();
+ }
+ graph.refresh();
+ }
+
+ /*************************************************************
+ *
+ */
+ public DataTransferModel getModel() {
+ if (model == null) {
+ setModel(new DataTransferModel());
+ }
+ return model;
+ }
+
+ /*************************************************************
+ *
+ */
+ public void setModel(DataTransferModel model) {
+ clear();
+ // Set the model.
+ this.model = model;
+
+ // Update the mxGraph.
+ graph = constructGraph(graph, model);
+ }
+
+ /*************************************************************
+ *
+ */
+ public boolean isValid() {
+ if (model == null) return false;
+ if (!Validation.checkUpdateConflict(model)) return false;
+ return true;
+ }
+
+ /*************************************************************
+ * Construct a mxGraph from DataFlowModel
+ * @param model
+ * @param dataFlowGraph
+ * @return constructed mxGraph
+ */
+ public mxGraph constructGraph(mxGraph graph, DataTransferModel model) {
+ bReflectingArchitectureModel = true;
+ mxCell root = (mxCell) graph.getDefaultParent();
+ mxCell nodeLayer = (mxCell) root.getChildAt(NODE_LAYER);
+ mxCell dataFlowLayer = (mxCell) root.getChildAt(DATA_FLOW_LAYER);
+
+ graph.getModel().beginUpdate();
+ try {
+ mxGeometry geo1 = new mxGeometry(0, 0.5, PORT_DIAMETER, PORT_DIAMETER);
+ geo1.setOffset(new mxPoint(-PORT_RADIUS, -PORT_RADIUS));
+ geo1.setRelative(true);
+
+ mxGeometry geo2 = new mxGeometry(1.0, 0.5, PORT_DIAMETER, PORT_DIAMETER);
+ geo2.setOffset(new mxPoint(-PORT_RADIUS, -PORT_RADIUS));
+ geo2.setRelative(true);
+
+ Map channelsIn = new HashMap<>();
+ Map channelsOut = new HashMap<>();
+ Map