revised readme.md

2023-01-11 17:13:06 -06:00
parent a8e37f705d
commit f8e8b2f05a
12 changed files with 839 additions and 143 deletions
@@ -0,0 +1,125 @@
+/** we define some extra tasks to be imported into main build or shared. */
+
+// load .env settings - mostly secrets
+task dotenv{
+  def ef=file('.env');
+  if(!ef.exists()) ef=file('../.env');
+  ef.readLines().each() {
+    if(it.isEmpty() || it.startsWith("#")) return true;
+    def (key,value)=it.tokenize('=')
+    project.ext.set(key,value)
+  }
+}
+task packageJavadoc(type: Jar, dependsOn: 'javadoc') {
+    from javadoc
+    classifier = 'javadoc'
+}
+task packageSources(type: Jar, dependsOn: 'classes') {
+    from sourceSets.main.allSource
+    classifier = 'sources'
+}
+task fat_jar(type: Jar) {
+    archiveBaseName = 'fat-'+project.name
+    archiveVersion =  project.version
+    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
+    /*
+    manifest {
+        attributes "Main-Class": mainClassName
+        attributes "Class-Path": configurations.runtimeClasspath.collect { it.getName() }.join(' ')
+    }
+    */
+    from { 
+        configurations.runtimeClasspath.collect { it.isDirectory() ? it : zipTree(it) } 
+    }{
+        exclude "META-INF/NOTICE.txt"    
+        exclude "META-INF/LICENSE"    
+    }
+    with jar
+}
+
+/**
+We define a singleton pattern using background thread to launch a blocking process.
+Later we make sure to terminate previous running driver threads before starting new.
+Also we split start, stop because we might not run in continouse mode.
+ */
+class Server implements Runnable{
+  static Server singleton=null;
+  public static Server main(){
+    if(singleton==null) singleton=new Server();
+    return singleton;
+  }
+  //org.slf4j.Logger log=null;
+  Thread driver=null;
+  Runnable task=null;
+  protected Server(){}
+  public void info(String msg){
+    //if(log!=null) log.info(msg); else println(msg);
+    println(msg);
+  }
+  //public Server setLogger(org.slf4j.Logger l){
+  //  log=l;
+  //  return this;
+  //}
+  public Server useDriver(boolean f){
+    info("using driver:"+f);
+    if(f){
+      driver=new Thread(this);
+      driver.setName("server.driver");
+    }else{
+      driver=null;
+    }
+    return this;
+  }
+  public void run(){
+    info("running task");
+    try{
+      task.run();
+    }catch(java.lang.Exception ex){
+      info("running task:interrupted");
+    }
+  }
+  public Server start(Runnable c){
+    info("starting server");
+    this.task=c;
+    if(driver!=null){
+        driver.start(); 
+    }else{
+        this.run();
+    }
+    return this;
+  }
+  public Server stop(){
+    info("stopping server");
+    if(driver!=null){
+      driver.interrupt();
+      driver.join();
+    }
+    for(Thread th:Thread.getAllStackTraces().keySet()){
+      if(th.getName().equalsIgnoreCase("executor")){
+        info("cleaning up stale driver:"+th.toString())
+        th.stop();
+      }
+      if(th.getName().equalsIgnoreCase("server.driver")){
+        info("cleaning up stale driver:"+th.toString())
+        th.stop();
+      }
+    }
+    return this;
+  }
+}
+task runServer{
+  inputs.files 'src'
+  doFirst {
+    boolean threaded=project.gradle.startParameter.continuous;
+    Server.main().stop().useDriver(threaded);//.setLogger(logger);
+  }
+  doLast {
+    Server.main().start({
+        project.javaexec {
+          classpath = project.sourceSets.main.runtimeClasspath
+          main = mainClassName
+        } 
+    });
+  }
+}
+