add xtralink module

Author: azahnen

.github/workflows/snapshot.yml

@@ -38,6 +38,7 @@ jobs:
       - if: ${{ matrix.os.platform != 'linux-amd64' }}
         name: java
         run: |
+          ./gradlew --no-parallel --no-configuration-cache :xtraplatform-xtralink:buildXtralinkJava -Pbranch=${{ github.ref_name }} -PdeployUser=${{ secrets.deploy_user }} -PdeployPassword=${{ secrets.deploy_password }}
           ./gradlew --no-parallel --no-configuration-cache publish -Pbranch=${{ github.ref_name }} -PdeployUser=${{ secrets.deploy_user }} -PdeployPassword=${{ secrets.deploy_password }}
 
       - if: ${{ matrix.os.platform == 'linux-amd64' }}
@@ -55,4 +56,5 @@ jobs:
             dnf install -y java-25-openjdk-devel g++ cmake
             pwd
             ls -l
+            ./gradlew --no-parallel --no-configuration-cache :xtraplatform-xtralink:buildXtralinkJava -Pbranch=${{ github.ref_name }} -PdeployUser=${{ secrets.deploy_user }} -PdeployPassword=${{ secrets.deploy_password }}
             ./gradlew --no-parallel --no-configuration-cache publish -Pbranch=${{ github.ref_name }} -PdeployUser=${{ secrets.deploy_user }} -PdeployPassword=${{ secrets.deploy_password }}

settings.gradle

@@ -38,3 +38,11 @@ xtraplatform {
 }
 
 rootProject.name = 'xtraplatform-native'
+
+dependencyResolutionManagement {
+    repositories {
+        flatDir {
+            dirs 'xtraplatform-xtralink/build/xtralink/ffi/java/build/libs/'
+        }
+    }
+}

xtraplatform-xtralink/build.gradle

@@ -0,0 +1,105 @@
+plugins {
+    id "de.undercouch.download" version "4.1.2"
+}
+
+maturity = 'MATURE'
+maintenance = 'FULL'
+description = 'xtralink integration, jobs and store.'
+//docIgnore = true
+
+ext {
+    xtralinkVersion = '0.9.3'
+    buildVersion = '0'
+    xtralinkBuildDir = new File(buildDir, 'xtralink')
+    xtralinkLibDir = new File(xtralinkBuildDir, 'dist')
+    xtralinkLibName = project.osdetector.os == 'osx' ? 'libxtralink.dylib' : 'libxtralink.so'
+    generatedResourcesDir = new File(buildDir, 'generated/src/main/resources/')
+    embeddedLibDir = new File(generatedResourcesDir, "xtralink-${xtralinkVersion}-${buildVersion}/lib")
+}
+
+dependencies {
+    provided project(':xtraplatform-nativ-loader')
+
+    embedded name: "xtralink-${xtralinkVersion}"
+}
+
+project.sourceSets.main.output.dir(generatedResourcesDir)
+
+def downloadXtralink = tasks.register('downloadXtralink', Download, {
+    src "https://github.com/ldproxy/xtralink/archive/refs/tags/v${xtralinkVersion}.tar.gz"
+    dest new File(new File(System.getProperty("java.io.tmpdir")), "xtralink-${xtralinkVersion}.tar.gz")
+    overwrite false
+})
+
+def getXtralink = tasks.register('getXtralink', Copy, {
+    dependsOn downloadXtralink
+    from(tarTree(downloadXtralink.get().dest)) {
+        eachFile { fcd ->
+            fcd.relativePath = new RelativePath(true, fcd.relativePath.segments.drop(1))
+        }
+        includeEmptyDirs = false
+    }
+    //from(new File(projectDir, '../../../ws-xtrahub/xtralink'))
+    //exclude 'data/**'
+
+    into xtralinkBuildDir
+    def copyDetails = []
+    eachFile { copyDetails << it }
+    doLast {
+        copyDetails.each { FileCopyDetails details ->
+            def target = new File(destinationDir, details.path)
+            if(target.exists()) { target.setLastModified(details.lastModified) }
+        }
+    }
+})
+
+tasks.register('buildXtralink', Exec, {
+    dependsOn(tasks.getXtralink)
+    inputs.dir xtralinkBuildDir
+    workingDir new File(xtralinkBuildDir, 'ffi/clib/main')
+    commandLine 'make', 'shared', 'OUT=../../../dist/'
+})
+
+def buildXtralinkJava= tasks.register('buildXtralinkJava', Exec, {
+    dependsOn(tasks.getXtralink)
+    inputs.dir xtralinkBuildDir
+    workingDir new File(xtralinkBuildDir, 'ffi/java')
+    commandLine './gradlew', 'build'
+})
+
+def copyXtralinkLib = tasks.register('copyXtralinkLib', Copy, {
+    dependsOn tasks.buildXtralink
+    from(xtralinkLibDir) {
+        include xtralinkLibName
+    }
+    into embeddedLibDir
+})
+
+tasks.named('jar') {
+    dependsOn copyXtralinkLib
+}
+tasks.named('cyclonedxDirectBom') {
+    dependsOn buildXtralinkJava
+}
+tasks.withType(Pmd).configureEach {
+    dependsOn copyXtralinkLib
+}
+
+project.subprojects { Project subproject ->
+    if (subproject.name.endsWith("-tpl")) {
+        subproject.afterEvaluate {
+            subproject.tasks.named("compileJava") {
+                dependsOn buildXtralinkJava
+            }
+            subproject.tasks.named("cyclonedxDirectBom") {
+                dependsOn buildXtralinkJava
+            }
+            subproject.tasks.named("javadocJar") {
+                dependsOn buildXtralinkJava
+            }
+            subproject.tasks.named("sourcesJar") {
+                dependsOn buildXtralinkJava
+            }
+        }
+    }
+}

xtraplatform-xtralink/genffi.config.ts

@@ -0,0 +1,115 @@
+import type { Config } from "genffi";
+
+export default {
+  outDir: "./src/main",
+  verbose: true,
+
+  //schema: { label: "Example JSON Schema" },
+
+  java: {
+    pkg: "de.ii.xtraplatform.xtralink.domain.jobs",
+    api: {
+      pkg: "de.ii.xtraplatform.xtralink.app.jobs",
+    },
+  },
+
+  go: {
+    path: "go",
+    //pkgPrefix: "xtralink",
+    module: "github.com/xtraplatform-native/xtralink",
+    mod: {},
+    api: {},
+    cgo: {
+      init: true,
+    },
+    impl: {},
+    model: {},
+  },
+} satisfies Config;
+
+export namespace GenModel {
+  export namespace Enums {
+    export enum Status {
+      ACCEPTED = "ACCEPTED",
+      RUNNING = "RUNNING",
+      SUCCESSFUL = "SUCCESSFUL",
+      FAILED = "FAILED",
+      DISMISSED = "DISMISSED",
+    }
+  }
+
+  export namespace Config {
+    export type Job = {
+      id: string;
+      kind: string;
+      createdAt: number;
+      startedAt: number;
+      updatedAt: number;
+      finishedAt: number;
+      status: Enums.Status;
+      progress: number;
+      errors: string[];
+    };
+    export type JobResult = {
+      message: string;
+      status: Enums.Status;
+      errors: string[];
+    };
+  }
+}
+
+export namespace GenApi {
+
+  export type int = number & { readonly __int: unique symbol };
+
+  /**
+   * @listener
+   */
+  export interface JobListener {
+    onProgress: (job: GenModel.Config.Job) => void;
+  }
+
+  /**
+   * @listener
+   */
+  export interface JobProcessor {
+    /**
+     * @throws
+     */
+    process: (job: GenModel.Config.Job) => GenModel.Config.JobResult;
+  }
+
+  /**
+   * The one globally reachable object. `InitLibrary()` creates it by calling
+   * `clib.NewInit()`, which you have to write by hand — it is the single obligation
+   * genffi places on the implementation side.
+   * @singleton
+   */
+  export interface JobQueue {
+    create: (jobType: string) => GenModel.Config.Job;
+
+    /**
+     * The same thing through a `@scoped` listener, whose Java overload takes the interface
+     * itself and manages the registration around the call. A single-method listener, so the
+     * call site can be a lambda — which is the whole point of the tag and the one thing a
+     * compile cannot prove is *usable*.
+     * @scoped
+     */
+    push: (
+      cfg: GenModel.Config.Job,
+      onProgress: JobListener,
+    ) => Promise<GenModel.Config.Job>;
+
+    get: (id: string) => GenModel.Config.Job;
+  }
+
+  /**
+   * The one globally reachable object. `InitLibrary()` creates it by calling
+   * `clib.NewInit()`, which you have to write by hand — it is the single obligation
+   * genffi places on the implementation side.
+   * @singleton
+   */
+  export interface JobProcessors {
+    register: (jobType: string, processor: JobProcessor) => boolean;
+  }
+}

xtraplatform-xtralink/package-lock.json

@@ -0,0 +1,10 @@
+{
+  "type": "module",
+  "private": true,
+  "scripts": {
+    "genffi": "genffi"
+  },
+  "devDependencies": {
+    "genffi": "file:../../genffi"
+  }
+}