-
Notifications
You must be signed in to change notification settings - Fork 9
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
222 changed files
with
13,416 additions
and
4,141 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,155 @@ | ||
| # This file is autogenerated | ||
|
|
||
| {.warning[UnusedImport]: off.} | ||
| import pixie, json, times, strformat, strutils, sequtils, options | ||
|
|
||
| import frameos/types | ||
| import frameos/channels | ||
| import frameos/utils/image | ||
| import frameos/utils/url | ||
| import apps/render/image/app as render_imageApp | ||
| import apps/data/downloadImage/app as data_downloadImageApp | ||
| import apps/render/split/app as render_splitApp | ||
| import apps/render/color/app as render_colorApp | ||
|
|
||
| const DEBUG = false | ||
| let PUBLIC_STATE_FIELDS*: seq[StateField] = @[] | ||
| let PERSISTED_STATE_KEYS*: seq[string] = @[] | ||
|
|
||
| type Scene* = ref object of FrameScene | ||
| node1: render_imageApp.App | ||
| node2: data_downloadImageApp.App | ||
| node3: render_splitApp.App | ||
| node4: render_colorApp.App | ||
| node5: render_imageApp.App | ||
| node6: data_downloadImageApp.App | ||
|
|
||
| {.push hint[XDeclaredButNotUsed]: off.} | ||
| var cache0: Option[Image] = none(Image) | ||
| var cache0Time: float = 0 | ||
| var cache1: Option[Image] = none(Image) | ||
| var cache1Time: float = 0 | ||
|
|
||
| proc runNode*(self: Scene, nodeId: NodeId, context: var ExecutionContext) = | ||
| let scene = self | ||
| let frameConfig = scene.frameConfig | ||
| let state = scene.state | ||
| var nextNode = nodeId | ||
| var currentNode = nodeId | ||
| var timer = epochTime() | ||
| while nextNode != -1.NodeId: | ||
| currentNode = nextNode | ||
| timer = epochTime() | ||
| case nextNode: | ||
| of 1.NodeId: # render/image | ||
| self.node1.appConfig.image = block: | ||
| if cache0.isNone() or epochTime() > cache0Time + 900.0: | ||
| cache0 = some(block: | ||
| self.node2.get(context)) | ||
| cache0Time = epochTime() | ||
| cache0.get() | ||
| self.node1.run(context) | ||
| nextNode = -1.NodeId | ||
| of 3.NodeId: # render/split | ||
| self.node3.run(context) | ||
| nextNode = -1.NodeId | ||
| of 5.NodeId: # render/image | ||
| self.node5.appConfig.image = block: | ||
| if cache1.isNone() or epochTime() > cache1Time + 900.0: | ||
| cache1 = some(block: | ||
| self.node6.get(context)) | ||
| cache1Time = epochTime() | ||
| cache1.get() | ||
| self.node5.run(context) | ||
| nextNode = -1.NodeId | ||
| of 4.NodeId: # render/color | ||
| self.node4.run(context) | ||
| nextNode = 1.NodeId | ||
| else: | ||
| nextNode = -1.NodeId | ||
|
|
||
| if DEBUG: | ||
| self.logger.log(%*{"event": "debug:scene", "node": currentNode, "ms": (-timer + epochTime()) * 1000}) | ||
|
|
||
| proc runEvent*(context: var ExecutionContext) = | ||
| let self = Scene(context.scene) | ||
| case context.event: | ||
| of "render": | ||
| try: self.runNode(3.NodeId, context) | ||
| except Exception as e: self.logger.log(%*{"event": "render:error", "node": 3, "error": $e.msg, "stacktrace": e.getStackTrace()}) | ||
| of "setSceneState": | ||
| if context.payload.hasKey("state") and context.payload["state"].kind == JObject: | ||
| let payload = context.payload["state"] | ||
| for field in PUBLIC_STATE_FIELDS: | ||
| let key = field.name | ||
| if payload.hasKey(key) and payload[key] != self.state{key}: | ||
| self.state[key] = copy(payload[key]) | ||
| if context.payload.hasKey("render"): | ||
| sendEvent("render", %*{}) | ||
| else: discard | ||
|
|
||
| proc render*(self: FrameScene, context: var ExecutionContext): Image = | ||
| let self = Scene(self) | ||
| context.image.fill(self.backgroundColor) | ||
| runEvent(context) | ||
|
|
||
| return context.image | ||
|
|
||
| proc init*(sceneId: SceneId, frameConfig: FrameConfig, logger: Logger, persistedState: JsonNode): FrameScene = | ||
| var state = %*{} | ||
| if persistedState.kind == JObject: | ||
| for key in persistedState.keys: | ||
| state[key] = persistedState[key] | ||
| let scene = Scene(id: sceneId, frameConfig: frameConfig, state: state, logger: logger, refreshInterval: 300.0, backgroundColor: parseHtmlColor("#ffffff")) | ||
| let self = scene | ||
| result = scene | ||
| var context = ExecutionContext(scene: scene, event: "init", payload: state, hasImage: false, loopIndex: 0, loopKey: ".") | ||
| scene.execNode = (proc(nodeId: NodeId, context: var ExecutionContext) = scene.runNode(nodeId, context)) | ||
| scene.node1 = render_imageApp.App(nodeName: "render/image", nodeId: 1.NodeId, scene: scene.FrameScene, frameConfig: scene.frameConfig, appConfig: render_imageApp.AppConfig( | ||
| placement: "center", | ||
| inputImage: none(Image), | ||
| offsetX: 0, | ||
| offsetY: 0, | ||
| )) | ||
| scene.node2 = data_downloadImageApp.App(nodeName: "data/downloadImage", nodeId: 2.NodeId, scene: scene.FrameScene, frameConfig: scene.frameConfig, appConfig: data_downloadImageApp.AppConfig( | ||
| url: "https://frameos.net/img/logo_in_ci_tests.png", | ||
| )) | ||
| scene.node3 = render_splitApp.App(nodeName: "render/split", nodeId: 3.NodeId, scene: scene.FrameScene, frameConfig: scene.frameConfig, appConfig: render_splitApp.AppConfig( | ||
| rows: 2, | ||
| inputImage: none(Image), | ||
| columns: 1, | ||
| hideEmpty: false, | ||
| render_functions: @[ | ||
| @[ | ||
| 4.NodeId, | ||
| ], | ||
| @[ | ||
| 5.NodeId, | ||
| ], | ||
| ], | ||
| render_function: 0.NodeId, | ||
| )) | ||
| scene.node5 = render_imageApp.App(nodeName: "render/image", nodeId: 5.NodeId, scene: scene.FrameScene, frameConfig: scene.frameConfig, appConfig: render_imageApp.AppConfig( | ||
| inputImage: none(Image), | ||
| placement: "cover", | ||
| offsetX: 0, | ||
| offsetY: 0, | ||
| )) | ||
| scene.node6 = data_downloadImageApp.App(nodeName: "data/downloadImage", nodeId: 6.NodeId, scene: scene.FrameScene, frameConfig: scene.frameConfig, appConfig: data_downloadImageApp.AppConfig( | ||
| url: "this is not an url", | ||
| )) | ||
| scene.node4 = render_colorApp.App(nodeName: "render/color", nodeId: 4.NodeId, scene: scene.FrameScene, frameConfig: scene.frameConfig, appConfig: render_colorApp.AppConfig( | ||
| inputImage: none(Image), | ||
| color: parseHtmlColor("#ffffff"), | ||
| )) | ||
| runEvent(context) | ||
|
|
||
| {.pop.} | ||
|
|
||
| var exportedScene* = ExportedScene( | ||
| publicStateFields: PUBLIC_STATE_FIELDS, | ||
| persistedStateKeys: PERSISTED_STATE_KEYS, | ||
| init: init, | ||
| runEvent: runEvent, | ||
| render: render | ||
| ) |
Oops, something went wrong.