From 0c3367586050e6a1a65970b7bc5d282c8cb24ea7 Mon Sep 17 00:00:00 2001 From: Edouard DUPIN Date: Thu, 29 Dec 2022 21:15:49 +0100 Subject: [PATCH] [DEV] add back --- .checkstyle | 10 + .gitignore | 64 +++ Dockerfile | 79 ++++ back/CheckStyle.xml | 66 ++++ back/CleanUp.xml | 66 ++++ back/Dockerfile | 21 + back/Formatter.xml | 366 ++++++++++++++++++ back/LICENSE | 6 + back/README.md | 18 + back/db.sql | 4 + back/pom.xml | 174 +++++++++ back/src/org/kar/karanage/WebLauncher.java | 118 ++++++ .../org/kar/karanage/WebLauncherLocal.java | 16 + back/src/org/kar/karanage/api/Front.java | 22 ++ .../src/org/kar/karanage/api/HealthCheck.java | 28 ++ .../org/kar/karanage/api/StateResource.java | 111 ++++++ .../org/kar/karanage/api/UserResource.java | 101 +++++ back/src/org/kar/karanage/internal/Log.java | 60 +++ .../kar/karanage/model/ApplicationToken.java | 37 ++ .../org/kar/karanage/model/DataHistory.java | 74 ++++ .../org/kar/karanage/model/DataInstant.java | 59 +++ back/src/org/kar/karanage/model/Group.java | 24 ++ .../org/kar/karanage/model/UserKaranage.java | 14 + .../org/kar/karanage/util/ConfigVariable.java | 15 + device_script/.karanage.json | 18 + device_script/inspect.py | 177 +++++++++ docker-compose.yaml | 46 +++ 27 files changed, 1794 insertions(+) create mode 100644 .checkstyle create mode 100644 .gitignore create mode 100644 Dockerfile create mode 100755 back/CheckStyle.xml create mode 100644 back/CleanUp.xml create mode 100644 back/Dockerfile create mode 100644 back/Formatter.xml create mode 100644 back/LICENSE create mode 100644 back/README.md create mode 100644 back/db.sql create mode 100644 back/pom.xml create mode 100755 back/src/org/kar/karanage/WebLauncher.java create mode 100755 back/src/org/kar/karanage/WebLauncherLocal.java create mode 100644 back/src/org/kar/karanage/api/Front.java create mode 100644 back/src/org/kar/karanage/api/HealthCheck.java create mode 100644 back/src/org/kar/karanage/api/StateResource.java create mode 100755 back/src/org/kar/karanage/api/UserResource.java create mode 100644 back/src/org/kar/karanage/internal/Log.java create mode 100644 back/src/org/kar/karanage/model/ApplicationToken.java create mode 100644 back/src/org/kar/karanage/model/DataHistory.java create mode 100644 back/src/org/kar/karanage/model/DataInstant.java create mode 100644 back/src/org/kar/karanage/model/Group.java create mode 100644 back/src/org/kar/karanage/model/UserKaranage.java create mode 100644 back/src/org/kar/karanage/util/ConfigVariable.java create mode 100644 device_script/.karanage.json create mode 100755 device_script/inspect.py create mode 100644 docker-compose.yaml diff --git a/.checkstyle b/.checkstyle new file mode 100644 index 0000000..d6e04dd --- /dev/null +++ b/.checkstyle @@ -0,0 +1,10 @@ + + + + + + + + + + diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..1f5659b --- /dev/null +++ b/.gitignore @@ -0,0 +1,64 @@ +# See http://help.github.com/ignore-files/ for more about ignoring files. +out +.idea + +# compiled output +/dist +/dist-server +/tmp +/out-tsc + +/front/dist + +config.env + +*.class + +dataPush +node_modules + +# dependencies +applicationFront/node_modules + +# IDEs and editors +/.idea +.project +.classpath +.c9/ +*.launch +.settings/ +*.sublime-workspace + +# IDE - VSCode +.vscode/* +!.vscode/settings.json +!.vscode/tasks.json +!.vscode/launch.json +!.vscode/extensions.json + +# misc +/.sass-cache +/connect.lock +/coverage +/libpeerconnection.log +npm-debug.log +yarn-error.log +testem.log +/typings + +# e2e +/e2e/*.js +/e2e/*.map + +# System Files +.DS_Store +Thumbs.db + +backPY/env + +*.pyc + +__pycache__ + +.design/ +.vscode/ diff --git a/Dockerfile b/Dockerfile new file mode 100644 index 0000000..5f3781a --- /dev/null +++ b/Dockerfile @@ -0,0 +1,79 @@ +###################################################################################### +## +## buyilding-end install applications: +## +###################################################################################### +FROM archlinux:base-devel AS builder +# update system +RUN pacman -Syu --noconfirm && pacman-db-upgrade \ + && pacman -S --noconfirm jdk-openjdk maven npm \ + && pacman -Scc --noconfirm + +ENV PATH /tmp/node_modules/.bin:$PATH +WORKDIR /tmp + +###################################################################################### +## +## Build back: +## +###################################################################################### +FROM builder AS buildBack +COPY back/pom.xml /tmp +COPY back/src /tmp/src/ +RUN mvn clean compile assembly:single + +###################################################################################### +## +## Build front: +## +###################################################################################### +FROM builder AS buildFront + +ADD front/package-lock.json \ + front/package.json \ + front/karma.conf.js \ + front/protractor.conf.js \ + /tmp/ + +# install and cache app dependencies +RUN npm install + +ADD front/e2e \ + front/tsconfig.json \ + front/tslint.json \ + front/angular.json \ + /tmp/ +ADD front/src /tmp/src + +# generate build +RUN ng build --output-path=dist --configuration=production --base-href=/karusic/ --deploy-url=/karusic/ + +###################################################################################### +## +## Production area: +## +###################################################################################### + +FROM bellsoft/liberica-openjdk-alpine:latest +# add wget to manage the health check... +RUN apk add --no-cache wget + +#FROM archlinux:base +#RUN pacman -Syu --noconfirm && pacman-db-upgrade +## install package +#RUN pacman -S --noconfirm jdk-openjdk wget +## intall npm +#RUN pacman -S --noconfirm npm +## clean all the caches Need only on the release environment +#RUN pacman -Scc --noconfirm + +ENV LANG=C.UTF-8 + +COPY --from=buildBack /tmp/out/maven/*.jar /application/application.jar +COPY --from=buildFront /tmp/dist /application/front/ + +WORKDIR /application/ + +EXPOSE 80 + +CMD ["java", "-Xms64M", "-Xmx1G", "-cp", "/application/application.jar", "org.kar.karusic.WebLauncher"] diff --git a/back/CheckStyle.xml b/back/CheckStyle.xml new file mode 100755 index 0000000..d68aedd --- /dev/null +++ b/back/CheckStyle.xml @@ -0,0 +1,66 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/back/CleanUp.xml b/back/CleanUp.xml new file mode 100644 index 0000000..9df98d2 --- /dev/null +++ b/back/CleanUp.xml @@ -0,0 +1,66 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/back/Dockerfile b/back/Dockerfile new file mode 100644 index 0000000..8fc1c69 --- /dev/null +++ b/back/Dockerfile @@ -0,0 +1,21 @@ +FROM maven:3.6.3-openjdk-16 AS build + +COPY pom.xml /tmp/ +COPY src /tmp/src/ +WORKDIR /tmp/ +RUN mvn clean compile assembly:single + + + +FROM bellsoft/liberica-openjdk-alpine:latest +ENV LANG=C.UTF-8 + + +RUN mkdir /application/ +COPY --from=build /tmp/out/maven/*.jar /application/application.jar +WORKDIR /application/ + +EXPOSE 18080 + +CMD ["java", "-Xms64M", "-Xmx1G", "-cp", "/application/application.jar", "org.kar.karusic.WebLauncher"] + diff --git a/back/Formatter.xml b/back/Formatter.xml new file mode 100644 index 0000000..b775e22 --- /dev/null +++ b/back/Formatter.xml @@ -0,0 +1,366 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/back/LICENSE b/back/LICENSE new file mode 100644 index 0000000..a9d1e81 --- /dev/null +++ b/back/LICENSE @@ -0,0 +1,6 @@ +PROPIETARY licence +================== + +Copyright at Edouard DUPIN + +you have no right \ No newline at end of file diff --git a/back/README.md b/back/README.md new file mode 100644 index 0000000..db094e1 --- /dev/null +++ b/back/README.md @@ -0,0 +1,18 @@ +Generic backend for karanage in java +=================================== + +Kar manage is a tool to keep result of system inpection like docker, ros diagnostics, system status ... + + + +mvn install + +// create a single package jar +mvn clean compile assembly:single + + + +java -cp out/maven/karanage-0.1.0-jar-with-dependencies.jar org.kar.karideo.WebLauncher + + + diff --git a/back/db.sql b/back/db.sql new file mode 100644 index 0000000..fd40910 --- /dev/null +++ b/back/db.sql @@ -0,0 +1,4 @@ + + + + diff --git a/back/pom.xml b/back/pom.xml new file mode 100644 index 0000000..0e5b697 --- /dev/null +++ b/back/pom.xml @@ -0,0 +1,174 @@ + + 4.0.0 + org.kar + karanage + 0.1.0 + + + 3.1 + 17 + 17 + + 3.1.1 + + + + gitea + https://gitea.atria-soft.org/api/packages/kangaroo-and-rabbit/maven + + + + + + kangaroo-and-rabbit + archidata + 0.1.3 + + + + + src + test/src + ${project.basedir}/out/maven/ + + + org.apache.maven.plugins + maven-compiler-plugin + ${maven.compiler.version} + + ${maven.compiler.source} + ${maven.compiler.target} + + + + + org.codehaus.mojo + exec-maven-plugin + 1.4.0 + + io.scenarium.oauth.WebLauncher + + + + + org.apache.maven.plugins + maven-source-plugin + + + attach-sources + + jar + + + + + + + org.apache.maven.plugins + maven-surefire-plugin + 3.0.0-M5 + + + maven-assembly-plugin + + + + fully.qualified.MainClass + + + + jar-with-dependencies + + + + + + + + org.apache.maven.plugins + maven-javadoc-plugin + 3.2.0 + + private + true + + + + + + + + + + + org.apache.maven.plugins + maven-javadoc-plugin + 3.2.0 + + public + + + + + + \ No newline at end of file diff --git a/back/src/org/kar/karanage/WebLauncher.java b/back/src/org/kar/karanage/WebLauncher.java new file mode 100755 index 0000000..c73e4f3 --- /dev/null +++ b/back/src/org/kar/karanage/WebLauncher.java @@ -0,0 +1,118 @@ +package org.kar.karanage; + +import java.net.URI; + +import javax.ws.rs.core.UriBuilder; + +import org.glassfish.grizzly.http.server.HttpServer; +import org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory; +import org.glassfish.jersey.jackson.JacksonFeature; +import org.glassfish.jersey.media.multipart.MultiPartFeature; +import org.glassfish.jersey.server.ResourceConfig; +import org.kar.karanage.api.Front; +import org.kar.karanage.api.HealthCheck; +import org.kar.karanage.api.StateResource; +import org.kar.karanage.api.UserResource; +import org.kar.archidata.GlobalConfiguration; +import org.kar.archidata.SqlWrapper; +import org.kar.archidata.UpdateJwtPublicKey; +import org.kar.archidata.filter.AuthenticationFilter; +import org.kar.archidata.filter.CORSFilter; +import org.kar.archidata.filter.OptionFilter; +import org.kar.archidata.util.ConfigBaseVariable; +import org.kar.karanage.model.DataHistory; +import org.kar.karanage.model.DataInstant; +import org.kar.karanage.model.Group; + +public class WebLauncher { + private WebLauncher() { + } + + private static URI getBaseURI() { + return UriBuilder.fromUri(ConfigBaseVariable.getlocalAddress()).build(); + } + + public static void main(String[] args) { + ConfigBaseVariable.bdDatabase = "karanage"; + + // generate the BDD: + try { + String out = ""; + out += SqlWrapper.createTable(DataInstant.class); + out += SqlWrapper.createTable(DataHistory.class); + out += SqlWrapper.createTable(Group.class); + System.out.println(out); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + // =================================================================== + // Configure resources + // =================================================================== + ResourceConfig rc = new ResourceConfig(); + + // add multipart models .. + rc.register(new MultiPartFeature()); + // global authentication system + rc.register(new OptionFilter()); + // remove cors ==> all time called by an other system... + rc.register(new CORSFilter()); + // global authentication system + rc.registerClasses(AuthenticationFilter.class); + // add default resource: + rc.registerClasses(UserResource.class); + rc.registerClasses(StateResource.class); + + rc.registerClasses(HealthCheck.class); + rc.registerClasses(Front.class); + + // add jackson to be discovenr when we are ins standalone server + rc.register(JacksonFeature.class); + // enable this to show low level request + //rc.property(LoggingFeature.LOGGING_FEATURE_LOGGER_LEVEL_SERVER, Level.WARNING.getName()); + + //System.out.println("Connect on the BDD:"); + //System.out.println(" getDBHost: '" + ConfigVariable.getDBHost() + "'"); + //System.out.println(" getDBPort: '" + ConfigVariable.getDBPort() + "'"); + //System.out.println(" getDBLogin: '" + ConfigVariable.getDBLogin() + "'"); + //System.out.println(" getDBPassword: '" + ConfigVariable.getDBPassword() + "'"); + //System.out.println(" getDBName: '" + ConfigVariable.getDBName() + "'"); + System.out.println(" ==> " + GlobalConfiguration.dbConfig); + System.out.println("OAuth service " + getBaseURI()); + HttpServer server = GrizzlyHttpServerFactory.createHttpServer(getBaseURI(), rc); + Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() { + @Override + public void run() { + System.out.println("Stopping server.."); + server.shutdownNow(); + } + }, "shutdownHook")); + + // =================================================================== + // start periodic update of the token ... + // =================================================================== + UpdateJwtPublicKey keyUpdater = new UpdateJwtPublicKey(); + keyUpdater.start(); + + // =================================================================== + // run JERSEY + // =================================================================== + try { + server.start(); + System.out.println("Jersey app started at " + getBaseURI()); + System.out.println("Press CTRL^C to exit.."); + Thread.currentThread().join(); + } catch (Exception e) { + System.out.println("There was an error while starting Grizzly HTTP server."); + e.printStackTrace(); + } + keyUpdater.kill(); + try { + keyUpdater.join(4000, 0); + } catch (InterruptedException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } +} diff --git a/back/src/org/kar/karanage/WebLauncherLocal.java b/back/src/org/kar/karanage/WebLauncherLocal.java new file mode 100755 index 0000000..659f9ad --- /dev/null +++ b/back/src/org/kar/karanage/WebLauncherLocal.java @@ -0,0 +1,16 @@ +package org.kar.karanage; + +import org.kar.archidata.util.ConfigBaseVariable; + +public class WebLauncherLocal { + private WebLauncherLocal() {} + + public static void main(String[] args) throws InterruptedException { + if (true) { + // for local test: + ConfigBaseVariable.apiAdress = "http://0.0.0.0:20080/karanage/api/"; + ConfigBaseVariable.ssoAdress = "https://atria-soft.org/karso/api/"; + } + WebLauncher.main(args); + } +} diff --git a/back/src/org/kar/karanage/api/Front.java b/back/src/org/kar/karanage/api/Front.java new file mode 100644 index 0000000..b7018cd --- /dev/null +++ b/back/src/org/kar/karanage/api/Front.java @@ -0,0 +1,22 @@ +package org.kar.karanage.api; + +import java.io.File; +import java.util.List; + +import org.kar.archidata.annotation.security.PermitAll; +import javax.ws.rs.*; +import javax.ws.rs.core.CacheControl; +import javax.ws.rs.core.PathSegment; +import javax.ws.rs.core.Response; +import javax.ws.rs.core.Response.ResponseBuilder; + +import org.kar.archidata.api.FrontGeneric; +import org.kar.karanage.util.ConfigVariable; + +@Path("/karanage") +public class Front extends FrontGeneric { + public Front() { + this.baseFrontFolder = ConfigVariable.getFrontFolder(); + + } +} diff --git a/back/src/org/kar/karanage/api/HealthCheck.java b/back/src/org/kar/karanage/api/HealthCheck.java new file mode 100644 index 0000000..c71a77d --- /dev/null +++ b/back/src/org/kar/karanage/api/HealthCheck.java @@ -0,0 +1,28 @@ +package org.kar.karanage.api; + +import org.kar.archidata.annotation.security.PermitAll; +import javax.ws.rs.core.Response; +import javax.ws.rs.*; +import javax.ws.rs.core.MediaType; + +import org.kar.archidata.util.JWTWrapper; + +@Path("/health_check") +@Produces(MediaType.APPLICATION_JSON) +public class HealthCheck { + public class HealthResult { + public String value; + public HealthResult(String value) { + this.value = value; + } + } + // todo : do it better... + @GET + @PermitAll + public Response getHealth() { + if (JWTWrapper.getPublicKey() == null) { + return Response.status(500).entity(new HealthResult("Missing Jwt public token")).build(); + } + return Response.status(200).entity(new HealthResult("alive and kicking")).build(); + } +} diff --git a/back/src/org/kar/karanage/api/StateResource.java b/back/src/org/kar/karanage/api/StateResource.java new file mode 100644 index 0000000..a19e36f --- /dev/null +++ b/back/src/org/kar/karanage/api/StateResource.java @@ -0,0 +1,111 @@ +package org.kar.karanage.api; + +import org.kar.archidata.SqlWrapper; +import org.kar.karanage.model.DataInstant; +import org.kar.karanage.model.DataHistory; +import org.kar.karanage.model.Group; +import javax.ws.rs.core.Response; + + +import org.kar.archidata.annotation.security.PermitAll; +import javax.ws.rs.*; +import javax.ws.rs.core.MediaType; + +import java.sql.Timestamp; +import java.time.Instant; +import java.time.OffsetDateTime; +import java.time.ZoneOffset; +import java.util.List; + + +@Path("/state") +@Produces({MediaType.APPLICATION_JSON}) +public class StateResource { + + @GET + @Path("{group}/{topic:.*}") + //@RolesAllowed("USER") + @PermitAll + public static DataInstant getWithTopic(@PathParam("group") String groupName, @PathParam("topic") String topic) throws Exception { + Group group = SqlWrapper.getWhere(Group.class, "name", "=", groupName); + if (group == null) { + throw new Exception("Missing Group !!!"); + } + return SqlWrapper.getWhere(DataInstant.class, "group", "=", group.id, "topic", "=", topic); + } + + @GET + @Path("{group}") + //@RolesAllowed("USER") + @PermitAll + public List get(@PathParam("group") String groupName) throws Exception { + Group group = SqlWrapper.getWhere(Group.class, "name", "=", groupName); + if (group == null) { + throw new Exception("Missing Group !!!"); + } + return SqlWrapper.getsWhere(DataInstant.class, "group", "=", group.id); + } + + @POST + @Path("{group}/{topic:.*}") + //@RolesAllowed("ADMIN") + @PermitAll + @Consumes(MediaType.APPLICATION_JSON) + public Response post(@PathParam("group") String groupName, @PathParam("topic") String topic, String dataToInsert) throws Exception { + DataInstant previous = null; + Group group = SqlWrapper.getWhere(Group.class, "name", "=", groupName); + if (group != null) { + previous = SqlWrapper.getWhere(DataInstant.class, "group", "=", group.id, "topic", "=", topic, true); + } + if (previous == null) { + // insert new data + DataInstant data = new DataInstant(); + data.group = group.id; + data.topic = topic; + data.data = dataToInsert; + previous = SqlWrapper.insert(data); + DataHistory dataHistory = new DataHistory(previous); + dataHistory.year = true; + dataHistory.month = true; + dataHistory.week = true; + dataHistory.day = true; + SqlWrapper.insert(dataHistory); + return Response.status(201).build(); + } + // update Data + try { + previous.data = dataToInsert; + SqlWrapper.update(previous, previous.id, List.of("data")); + // add it in history: + DataHistory dataHistory = new DataHistory(previous); + OffsetDateTime now = OffsetDateTime.now( ZoneOffset.UTC ); + OffsetDateTime sqlTime = OffsetDateTime.ofInstant(Instant.ofEpochMilli(previous.modify_date.getTime()), ZoneOffset.UTC); + //tstamp = Timestamp.valueOf(ofsdatetime.atZoneSameInstant(ZoneOffset.UTC).toLocalDateTime()) + + now.getDayOfMonth(); + if (sqlTime.getYear() != now.getYear()) { + dataHistory.year = true; + } + if (sqlTime.getMonth() != now.getMonth()) { + dataHistory.month = true; + } + if (!sqlTime.getDayOfWeek().equals(now.getDayOfWeek())) { + dataHistory.week = true; + } + if (sqlTime.getDayOfYear() != now.getDayOfYear()) { + dataHistory.day = true; + } + if (sqlTime.getHour() != now.getHour()) { + dataHistory.hour = true; + } + dataHistory.modify_date = Timestamp.valueOf(now.atZoneSameInstant(ZoneOffset.UTC).toLocalDateTime()); + + SqlWrapper.insert(dataHistory); + } catch (Exception ex) { + System.out.print("get exception: " + ex); + } + return Response.status(204).build(); + } + +} + diff --git a/back/src/org/kar/karanage/api/UserResource.java b/back/src/org/kar/karanage/api/UserResource.java new file mode 100755 index 0000000..94f7cff --- /dev/null +++ b/back/src/org/kar/karanage/api/UserResource.java @@ -0,0 +1,101 @@ +package org.kar.karanage.api; + +import org.kar.archidata.SqlWrapper; +import org.kar.archidata.filter.GenericContext; +import org.kar.archidata.model.User; +import org.kar.karanage.model.UserKaranage; + +import org.kar.archidata.annotation.security.RolesAllowed; +import javax.ws.rs.*; +import javax.ws.rs.core.Context; +import javax.ws.rs.core.MediaType; +import javax.ws.rs.core.SecurityContext; +import java.util.List; + + +@Path("/users") +@Produces({MediaType.APPLICATION_XML, MediaType.APPLICATION_JSON}) +public class UserResource { + + public UserResource() { + } + + // curl http://localhost:9993/api/users + @GET + @RolesAllowed("ADMIN") + public List getUsers() { + System.out.println("getUsers"); + try { + return SqlWrapper.gets(UserKaranage.class, false); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return null; + } + + // curl http://localhost:9993/api/users/3 + @GET + @Path("{id}") + @RolesAllowed("ADMIN") + public UserKaranage getUsers(@Context SecurityContext sc, @PathParam("id") long userId) { + System.out.println("getUser " + userId); + GenericContext gc = (GenericContext) sc.getUserPrincipal(); + System.out.println("==================================================="); + System.out.println("== USER ? " + gc.user); + System.out.println("==================================================="); + try { + return SqlWrapper.get(UserKaranage.class, userId); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + return null; + } + + // curl http://localhost:9993/api/users/3 + @GET + @Path("me") + @RolesAllowed("USER") + public User getMe(@Context SecurityContext sc) { + System.out.println("getMe()"); + GenericContext gc = (GenericContext) sc.getUserPrincipal(); + System.out.println("==================================================="); + System.out.println("== USER ? " + gc.user); + System.out.println("==================================================="); + return gc.user; + } + +} + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/back/src/org/kar/karanage/internal/Log.java b/back/src/org/kar/karanage/internal/Log.java new file mode 100644 index 0000000..a70acb7 --- /dev/null +++ b/back/src/org/kar/karanage/internal/Log.java @@ -0,0 +1,60 @@ +package org.kar.karanage.internal; + +//import io.scenarium.logger.LogLevel; +//import io.scenarium.logger.Logger; + +public class Log { +// private static final String LIB_NAME = "logger"; +// private static final String LIB_NAME_DRAW = Logger.getDrawableName(LIB_NAME); +// private static final boolean PRINT_CRITICAL = Logger.getNeedPrint(LIB_NAME, LogLevel.CRITICAL); +// private static final boolean PRINT_ERROR = Logger.getNeedPrint(LIB_NAME, LogLevel.ERROR); +// private static final boolean PRINT_WARNING = Logger.getNeedPrint(LIB_NAME, LogLevel.WARNING); +// private static final boolean PRINT_INFO = Logger.getNeedPrint(LIB_NAME, LogLevel.INFO); +// private static final boolean PRINT_DEBUG = Logger.getNeedPrint(LIB_NAME, LogLevel.DEBUG); +// private static final boolean PRINT_VERBOSE = Logger.getNeedPrint(LIB_NAME, LogLevel.VERBOSE); +// private static final boolean PRINT_TODO = Logger.getNeedPrint(LIB_NAME, LogLevel.TODO); +// private static final boolean PRINT_PRINT = Logger.getNeedPrint(LIB_NAME, LogLevel.PRINT); +// +// private Log() {} +// +// public static void print(String data) { +// if (PRINT_PRINT) +// Logger.print(LIB_NAME_DRAW, data); +// } +// +// public static void todo(String data) { +// if (PRINT_TODO) +// Logger.todo(LIB_NAME_DRAW, data); +// } +// +// public static void critical(String data) { +// if (PRINT_CRITICAL) +// Logger.critical(LIB_NAME_DRAW, data); +// } +// +// public static void error(String data) { +// if (PRINT_ERROR) +// Logger.error(LIB_NAME_DRAW, data); +// } +// +// public static void warning(String data) { +// if (PRINT_WARNING) +// Logger.warning(LIB_NAME_DRAW, data); +// } +// +// public static void info(String data) { +// if (PRINT_INFO) +// Logger.info(LIB_NAME_DRAW, data); +// } +// +// public static void debug(String data) { +// if (PRINT_DEBUG) +// Logger.debug(LIB_NAME_DRAW, data); +// } +// +// public static void verbose(String data) { +// if (PRINT_VERBOSE) +// Logger.verbose(LIB_NAME_DRAW, data); +// } + +} diff --git a/back/src/org/kar/karanage/model/ApplicationToken.java b/back/src/org/kar/karanage/model/ApplicationToken.java new file mode 100644 index 0000000..1cbf82d --- /dev/null +++ b/back/src/org/kar/karanage/model/ApplicationToken.java @@ -0,0 +1,37 @@ +package org.kar.karanage.model; +/* +CREATE TABLE `node` ( + `id` bigint NOT NULL COMMENT 'table ID' AUTO_INCREMENT PRIMARY KEY, + `deleted` BOOLEAN NOT NULL DEFAULT false, + `create_date` datetime NOT NULL DEFAULT now() COMMENT 'Time the element has been created', + `modify_date` datetime NOT NULL DEFAULT now() COMMENT 'Time the element has been update', + `type` enum("TYPE", "UNIVERS", "SERIE", "SAISON", "MEDIA") NOT NULL DEFAULT 'TYPE', + `name` TEXT COLLATE 'utf8_general_ci' NOT NULL, + `description` TEXT COLLATE 'utf8_general_ci', + `parent_id` bigint +) AUTO_INCREMENT=10; +*/ + +import org.kar.archidata.annotation.SQLComment; +import org.kar.archidata.annotation.SQLForeignKey; +import org.kar.archidata.annotation.SQLIfNotExists; +import org.kar.archidata.annotation.SQLLimitSize; +import org.kar.archidata.annotation.SQLTableName; +import org.kar.archidata.model.GenericTable; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; + +@SQLTableName ("applicationToken") +@SQLIfNotExists +@JsonSerialize(include=JsonSerialize.Inclusion.NON_NULL) +public class ApplicationToken extends GenericTable { + @SQLComment("Group of the element") + @SQLForeignKey("group") + public long group; + @SQLLimitSize(256) + @SQLComment("Token Of the application (must be use by only one application)") + public String token = null; + @SQLComment("Description of the Group") + @SQLLimitSize(1024) + public String description; +} \ No newline at end of file diff --git a/back/src/org/kar/karanage/model/DataHistory.java b/back/src/org/kar/karanage/model/DataHistory.java new file mode 100644 index 0000000..64a364c --- /dev/null +++ b/back/src/org/kar/karanage/model/DataHistory.java @@ -0,0 +1,74 @@ +package org.kar.karanage.model; +/* +CREATE TABLE `node` ( + `id` bigint NOT NULL COMMENT 'table ID' AUTO_INCREMENT PRIMARY KEY, + `deleted` BOOLEAN NOT NULL DEFAULT false, + `create_date` datetime NOT NULL DEFAULT now() COMMENT 'Time the element has been created', + `modify_date` datetime NOT NULL DEFAULT now() COMMENT 'Time the element has been update', + `type` enum("TYPE", "UNIVERS", "SERIE", "SAISON", "MEDIA") NOT NULL DEFAULT 'TYPE', + `name` TEXT COLLATE 'utf8_general_ci' NOT NULL, + `description` TEXT COLLATE 'utf8_general_ci', + `parent_id` bigint +) AUTO_INCREMENT=10; +*/ + +import java.sql.Timestamp; + +import org.kar.archidata.annotation.SQLAutoIncrement; +import org.kar.archidata.annotation.SQLComment; +import org.kar.archidata.annotation.SQLDefault; +import org.kar.archidata.annotation.SQLForeignKey; +import org.kar.archidata.annotation.SQLIfNotExists; +import org.kar.archidata.annotation.SQLLimitSize; +import org.kar.archidata.annotation.SQLNotNull; +import org.kar.archidata.annotation.SQLNotRead; +import org.kar.archidata.annotation.SQLPrimaryKey; +import org.kar.archidata.annotation.SQLTableName; +import org.kar.archidata.annotation.SQLUpdateTime; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; + + +enum State { + OK, FAIL, UNSTABLE, RETREIVING, HAPPY, FULL, EMPTY +} +enum TypeData { + NUMBER, BOOLEAN, JSON, STRING +} + +@SQLTableName ("dataHistory") +@SQLIfNotExists +@JsonSerialize(include=JsonSerialize.Inclusion.NON_NULL) +public class DataHistory extends DataInstant { + // default constructor + public DataHistory() { + + } + public DataHistory(DataInstant other) { + this.group = other.group; + this.topic = other.topic; + this.state = other.state; + this.data = other.data; + } + + @SQLComment("First message of the years (in GMT time)") + @SQLNotNull + @SQLDefault("0") + public boolean year = false; + @SQLComment("First message of the month (in GMT time)") + @SQLNotNull + @SQLDefault("0") + public boolean month = false; + @SQLComment("First message of the week: monday (in GMT time)") + @SQLNotNull + @SQLDefault("0") + public boolean week = false; + @SQLComment("First message of the day (in GMT time)") + @SQLNotNull + @SQLDefault("0") + public boolean day = false; + @SQLComment("First message of the hour (in GMT time)") + @SQLNotNull + @SQLDefault("0") + public boolean hour = false; +} \ No newline at end of file diff --git a/back/src/org/kar/karanage/model/DataInstant.java b/back/src/org/kar/karanage/model/DataInstant.java new file mode 100644 index 0000000..98cbb2b --- /dev/null +++ b/back/src/org/kar/karanage/model/DataInstant.java @@ -0,0 +1,59 @@ +package org.kar.karanage.model; +/* +CREATE TABLE `node` ( + `id` bigint NOT NULL COMMENT 'table ID' AUTO_INCREMENT PRIMARY KEY, + `deleted` BOOLEAN NOT NULL DEFAULT false, + `create_date` datetime NOT NULL DEFAULT now() COMMENT 'Time the element has been created', + `modify_date` datetime NOT NULL DEFAULT now() COMMENT 'Time the element has been update', + `type` enum("TYPE", "UNIVERS", "SERIE", "SAISON", "MEDIA") NOT NULL DEFAULT 'TYPE', + `name` TEXT COLLATE 'utf8_general_ci' NOT NULL, + `description` TEXT COLLATE 'utf8_general_ci', + `parent_id` bigint +) AUTO_INCREMENT=10; +*/ + +import java.sql.Timestamp; + +import org.kar.archidata.annotation.SQLAutoIncrement; +import org.kar.archidata.annotation.SQLComment; +import org.kar.archidata.annotation.SQLForeignKey; +import org.kar.archidata.annotation.SQLIfNotExists; +import org.kar.archidata.annotation.SQLLimitSize; +import org.kar.archidata.annotation.SQLNotNull; +import org.kar.archidata.annotation.SQLNotRead; +import org.kar.archidata.annotation.SQLPrimaryKey; +import org.kar.archidata.annotation.SQLTableName; +import org.kar.archidata.annotation.SQLUpdateTime; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; + +@SQLTableName ("data") +@SQLIfNotExists +@JsonSerialize(include=JsonSerialize.Inclusion.NON_NULL) +public class DataInstant { + @SQLAutoIncrement // Add AUTO_INCREMENT modifier + @SQLPrimaryKey // Create a PRIMARY KEY based on this field + @SQLNotNull + @SQLComment("Primary key of the base") + public Long id = null; + + // TODO: werll managed of the not read and not set update time at @now() si c'est pas bon .. + + //@SQLNotRead + @SQLUpdateTime + @SQLNotNull + @SQLComment("When update the object") + public Timestamp modify_date = null; + @SQLComment("Group of the element") + @SQLForeignKey("group") + public long group; + @SQLLimitSize(256) + @SQLComment("Topic of the message") + public String topic = null; + @SQLComment("State of the message") + @SQLLimitSize(25) + //public State state = null; + public String state = null; + @SQLComment("Message to store") + public String data = null; +} \ No newline at end of file diff --git a/back/src/org/kar/karanage/model/Group.java b/back/src/org/kar/karanage/model/Group.java new file mode 100644 index 0000000..43a8eb0 --- /dev/null +++ b/back/src/org/kar/karanage/model/Group.java @@ -0,0 +1,24 @@ +package org.kar.karanage.model; + +import org.kar.archidata.annotation.SQLComment; +import org.kar.archidata.annotation.SQLIfNotExists; +import org.kar.archidata.annotation.SQLLimitSize; +import org.kar.archidata.annotation.SQLNotNull; +import org.kar.archidata.annotation.SQLTableName; +import org.kar.archidata.model.GenericTable; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; + + +@SQLTableName ("group") +@SQLIfNotExists +@JsonSerialize(include=JsonSerialize.Inclusion.NON_NULL) +public class Group extends GenericTable { + @SQLNotNull + @SQLLimitSize(256) + @SQLComment("Name of the group.") + public String name; + @SQLComment("Description of the Group") + @SQLLimitSize(1024) + public String description; +} diff --git a/back/src/org/kar/karanage/model/UserKaranage.java b/back/src/org/kar/karanage/model/UserKaranage.java new file mode 100644 index 0000000..9db6992 --- /dev/null +++ b/back/src/org/kar/karanage/model/UserKaranage.java @@ -0,0 +1,14 @@ +package org.kar.karanage.model; + +import org.kar.archidata.annotation.SQLIfNotExists; +import org.kar.archidata.annotation.SQLTableName; +import org.kar.archidata.model.User; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; + +@SQLTableName ("user") +@SQLIfNotExists +@JsonSerialize(include=JsonSerialize.Inclusion.NON_NULL) +public class UserKaranage extends User { + +} diff --git a/back/src/org/kar/karanage/util/ConfigVariable.java b/back/src/org/kar/karanage/util/ConfigVariable.java new file mode 100644 index 0000000..fd2ea5e --- /dev/null +++ b/back/src/org/kar/karanage/util/ConfigVariable.java @@ -0,0 +1,15 @@ +package org.kar.karanage.util; + +public class ConfigVariable { + public static final String BASE_NAME = "ORG_KARUSIC_"; + + + public static String getFrontFolder() { + String out = System.getenv(BASE_NAME + "FRONT_FOLDER"); + if (out == null) { + return "/application/front"; + } + return out; + } + +} diff --git a/device_script/.karanage.json b/device_script/.karanage.json new file mode 100644 index 0000000..ae1a206 --- /dev/null +++ b/device_script/.karanage.json @@ -0,0 +1,18 @@ +{ + "cpu": "auto", + "memory": "auto", + "swap": "auto", + "drive": { + "include": [ + "/", + "/home", + "/home/heero/HDD1", + "/home/heero/HDD2" + ] + }, + "network": { + "include": [ + "enp34s0" + ] + } +} diff --git a/device_script/inspect.py b/device_script/inspect.py new file mode 100755 index 0000000..5735919 --- /dev/null +++ b/device_script/inspect.py @@ -0,0 +1,177 @@ +#!/bin/python3 +# Importing the library +import psutil +import argparse +import time +import subprocess +import json +from pathlib import Path +from typing import Dict, List +import requests + +parser = argparse.ArgumentParser() +parser.add_argument("-c", "--config", type=str, default=".karanage.json", help="json configuration file") +parser.add_argument("-u", "--url", type=str, default="http://localhost:20080/karanage/api/state", help="Base URL of the web service") +parser.add_argument("-g", "--group", type=str, default="home", help="Group the the message") +parser.add_argument("-t", "--topic", type=str, default="PC/system", help="Topic of the message") +parser.add_argument("-s", "--sleep", type=int, default=10, help="Periodicity of the messages") +args = parser.parse_args() + +if Path(args.config).exists(): + f = open(args.config, "r") + configuration = json.loads(f.read()) + f.close() +else: + configuration = { + "cpu": "auto", + "memory": "auto", + "swap": "auto", + "drive": "auto", + "network": "auto", + } + + +def send_to_server(data: Dict) -> None: + ret = requests.post(f"{args.url}/{args.group}/{args.topic}", json=out) + if 200 <= ret.status_code <= 299: + pass # print(f" ==> done {ret}") + else: + print(f" ==> An error occured in sending message to the server !! {ret}") + + +cpu_core_count = psutil.cpu_count(logical=False) +cpu_thread_count = psutil.cpu_count() + + +def get_mounts() -> Dict: + process = subprocess.Popen( + ["mount", "-v"], stdout=subprocess.PIPE, stderr=subprocess.PIPE + ) + stdout, stderr = process.communicate() + """get data format: + $ mount -v + proc on /proc type proc (rw,nosuid,nodev,noexec,relatime) + sys on /sys type sysfs (rw,nosuid,nodev,noexec,relatime) + dev on /dev type devtmpfs (rw,nosuid,relatime,size=7049156k,nr_inodes=1762289,mode=755,inode64) + run on /run type tmpfs (rw,nosuid,nodev,relatime,mode=755,inode64) + efivarfs on /sys/firmware/efi/efivars type efivarfs (rw,nosuid,nodev,noexec,relatime) + /dev/nvme0n1p5 on / type ext4 (rw,relatime,stripe=32) + """ + out = {} + lines = stdout.decode("utf-8").split("\n") + for line in lines: + tmp = line.split(" ") + if len(tmp) <= 2: + continue + if tmp[0].startswith('/dev/'): + out[tmp[2]] = tmp[0][5:] + return out + +mounting_points = get_mounts(); + +def filter(data: Dict, filter_list: List[str]) -> Dict: + out = {} + print(f"Request filter {data.keys()} with filter {filter_list}") + for key in data: + if key in filter_list: + out[key] = data[key] + return out + +def need_process(data: Dict) -> Dict: + return configuration["cpu"] == "auto" or "include" in configuration["cpu"] + + +def create_cpu_data() -> Dict: + # scpufreq(current=1605.5205625000003, min=400.0, max=4372.0) + cpu_frequency = psutil.cpu_freq(percpu=False) + cpu_percent_use = psutil.cpu_percent() + return { + "core": cpu_core_count, + "thread": cpu_thread_count, + "frequency": cpu_frequency.current, + "use": cpu_percent_use, + "max": cpu_frequency.max, + } + +def create_memory_data() -> Dict: + # svmem(total=14473519104, available=8289726464, percent=42.7, used=5380497408, free=3276263424, active=1775763456, inactive=8335540224, buffers=361771008, cached=5454987264, shared=243720192, slab=544526336) + mem = psutil.virtual_memory() + return { + "used": mem.used, + "total": mem.total, + } + +def create_swap_data() -> Dict: + # sswap(total=17179865088, used=262144, free=17179602944, percent=0.0, sin=0, sout=0) + swap = psutil.swap_memory() + return { + "used": swap.used, + "total": swap.total, + } +def create_drive_data() -> Dict: + tmp_elem = {} + # nvme0n1p1 => sdiskio(read_count=187, write_count=3, read_bytes=6002176, write_bytes=5120, read_time=36, write_time=7, read_merged_count=504, write_merged_count=0, busy_time=67) + drive_access = psutil.disk_io_counters(perdisk=True) + for elem in mounting_points: + # sdiskusage(total=255162540032, used=112077000704, free=130049380352, percent=46.3) + drive_usage = psutil.disk_usage(elem) + # print(f"plop {mounting_points[elem]} ==> {drive_access.keys()}") + if mounting_points[elem] in drive_access: + tmp_elem[elem] = { + "read_bytes": drive_access[mounting_points[elem]].read_bytes, + "write_bytes": drive_access[mounting_points[elem]].write_bytes, + "used": drive_usage.used, + "total": drive_usage.total, + } + else: + tmp_elem[elem] = { + "used": drive_usage.used, + "total": drive_usage.total, + } + return tmp_elem + +def create_network_data() -> Dict: + # eth0 => snetio(bytes_sent=0, bytes_recv=0, packets_sent=0, packets_recv=0, errin=0, errout=0, dropin=0, dropout=0) + data = psutil.net_io_counters(pernic=True) + tmp_elem = {} + for elem in data: + tmp_elem[elem] = { + "bytes_sent": data[elem].bytes_sent, + "bytes_recv": data[elem].bytes_recv, + } + return tmp_elem + +def agglutinate(configuration, name, data): + if configuration[name] == "auto": + return data + elif "include" in configuration[name]: + return filter(data, configuration[name]["include"]) + return none + +while True: + out = {} + if need_process(configuration["cpu"]): + base_elem = create_cpu_data() + out["cpu"] = agglutinate(configuration, "cpu", base_elem) + + if need_process(configuration["memory"]): + base_elem = create_memory_data() + out["memory"] = agglutinate(configuration, "memory", base_elem) + + if need_process(configuration["swap"]): + base_elem = create_swap_data() + out["swap"] = agglutinate(configuration, "swap", base_elem) + + if need_process(configuration["drive"]): + base_elem = create_drive_data() + out["drive"] = agglutinate(configuration, "drive", base_elem) + + if configuration["network"] == "auto" or "include" in configuration["network"]: + base_elem = create_network_data() + out["network"] = agglutinate(configuration, "network", base_elem) + + #print("Read new value:") + print(json.dumps(out, indent=4)) + send_to_server(out) + time.sleep(args.sleep) + diff --git a/docker-compose.yaml b/docker-compose.yaml new file mode 100644 index 0000000..d82f84d --- /dev/null +++ b/docker-compose.yaml @@ -0,0 +1,46 @@ +version: '3' + +services: + karusic_db_service: + image: mysql:latest + restart: always + command: --default-authentication-plugin=mysql_native_password + env_file: + - ./config.env + volumes: + - /workspace/data/karusic/db:/var/lib/mysql + mem_limit: 600m + healthcheck: + test: ["CMD", "mysqladmin" ,"ping", "-h", "localhost"] + timeout: 20s + retries: 10 + + karauth_adminer_service: + image: adminer:latest + restart: always + depends_on: + - karusic_db_service + ports: + - 19079:8080 + links: + - karusic_db_service:db + read_only: false + mem_limit: 100m + + karusic_back_service: + restart: always + image: gitea.atria-soft.org/kangaroo-and-rabbit/karusic:latest + depends_on: + - karusic_db_service + ports: + - 19080:18080 + env_file: + - ./config.env + links: + - karusic_db_service:db + read_only: true + mem_limit: 1200m + healthcheck: + test: ["CMD", "wget" ,"http://localhost:18080/karusic/api/health_check", "-O", "/dev/null"] + timeout: 20s + retries: 3