235 integrate auth usermgmt

BUILD

@@ -62,7 +62,7 @@ test_suite(
     tags = ["smoke"],
     tests = [
         "//core:smoke",
-        "//osiris/authentication:smoke",
+        "//osiris/auth:smoke",
         "//osiris/notification:smoke",
         "//osiris/query:smoke",
         "//osiris/usermgmt:smoke",
@@ -74,7 +74,7 @@ test_suite(
     tags = ["unit"],
     tests = [
         "//core:unit",
-        "//osiris/authentication:unit",
+        "//osiris/auth:unit",
         "//osiris/notification:unit",
         "//osiris/query:unit",
         "//osiris/usermgmt:unit",
@@ -86,7 +86,7 @@ test_suite(
     tags = ["integration"],
     tests = [
         "//core:integration",
-        "//osiris/authentication:integration",
+        "//osiris/auth:integration",
         "//osiris/notification:integration",
         "//osiris/query:integration",
         "//osiris/usermgmt:integration",
@@ -98,7 +98,7 @@ test_suite(
     tags = ["internal"],
     tests = [
         "//core:internal",
-        "//osiris/authentication:internal",
+        "//osiris/auth:internal",
         "//osiris/notification:internal",
         "//osiris/query:internal",
         "//osiris/usermgmt:internal",

CHANGELOG.md

@@ -4,6 +4,13 @@ All notable changes to this project will be documented in this file.
 ### [0.3.0] - 2020-04-24
 ##### Added
 - WIP
+- [#242](https://github.com/bptlab/cepta/pull/242)
+  - Abstractions for starting mongo containers in golang tests
+  - Implement e2e authentication via envoy `http.jwt_authn.v2alpha.JwtAuthentication`
+  - Utility script for generating private and public RSA keys and a jwk set
+  - Integration tests for authentication
+  - Integration of authentication in the frontend
+  - Add `auth` and `usermgmt` microservices in dev and prod docker env
 - [#231](https://github.com/bptlab/cepta/pull/231)
   - Track the average speed of transports
   - t.b.a.
@@ -15,6 +22,8 @@ All notable changes to this project will be documented in this file.
 
 ##### Changed
 - WIP
+- [#242](https://github.com/bptlab/cepta/pull/242)
+  - Complete rewrite of auth and user management microservices
 - [#217](https://github.com/bptlab/cepta/pull/217)
   - consistent naming of bazel targets
 

WORKSPACE

@@ -21,6 +21,7 @@ http_archive(
     sha256 = "b6670f9f43faa66e3009488bbd909bc7bc46a5a9661a33f6bc578068d1837f37",
     urls = ["https://github.com/bazelbuild/rules_nodejs/releases/download/1.3.0/rules_nodejs-1.3.0.tar.gz"],
 )
+
 #@unused
 load("@build_bazel_rules_nodejs//:index.bzl", "node_repositories")
 
@@ -132,6 +133,7 @@ FLINK_VERSION = "1.9.0"
 SCALA_VERSION = "2.11"
 
 RULES_JVM_EXTERNAL_TAG = "3.2"
+
 RULES_JVM_EXTERNAL_SHA = "82262ff4223c5fda6fb7ff8bd63db8131b51b413d26eb49e3131037e79e324af"
 
 http_archive(
@@ -789,8 +791,8 @@ go_repository(
 go_repository(
     name = "com_github_romnnn_bsonpb",
     importpath = "github.com/romnnn/bsonpb",
-    sum = "h1:Id1oYhizudmN8jN+74D2u9mahka6zaZgcrPWIMEp3BA=",
-    version = "v0.0.0-20200304155412-6da328480240",
+    sum = "h1:/8PmZgpI8+QeKJj+2VqBJILvYrKBdwFFxZJ1M6alZGc=",
+    version = "v0.0.3",
 )
 
 go_repository(
@@ -799,3 +801,101 @@ go_repository(
     sum = "h1:1s6q1ZYyBLbh+1YrcXKaugZ6u5MSq9R763oVpkwNU2I=",
     version = "v0.1.1",
 )
+
+go_repository(
+    name = "com_github_google_uuid",
+    importpath = "github.com/google/uuid",
+    sum = "h1:Gkbcsh/GbpXz7lPftLA3P6TYMwjCLYm83jiFQZF/3gY=",
+    version = "v1.1.1",
+)
+
+go_repository(
+    name = "com_github_testcontainers_testcontainers_go",
+    importpath = "github.com/testcontainers/testcontainers-go",
+    sum = "h1:u7jCdf130QHBY5KK9xkFzZpkep24Rtl8HdWscMO9H/8=",
+    version = "v0.5.0",
+)
+
+go_repository(
+    name = "com_github_docker_go_connections",
+    importpath = "github.com/docker/go-connections",
+    sum = "h1:El9xVISelRB7BuFusrZozjnkIM5YnzCViNKohAFqRJQ=",
+    version = "v0.4.0",
+)
+
+go_repository(
+    name = "com_github_docker_docker",
+    importpath = "github.com/docker/docker",
+    sum = "h1:ZuxGvIvF01nfc/G9RJ5Q7Va1zQE2WJyG18Zv3DqCEf4=",
+    version = "v0.7.3-0.20190506211059-b20a14b54661",
+)
+
+go_repository(
+    name = "com_github_cenkalti_backoff",
+    importpath = "github.com/cenkalti/backoff",
+    sum = "h1:tNowT99t7UNflLxfYYSlKYsBpXdEet03Pg2g16Swow4=",
+    version = "v2.2.1+incompatible",
+)
+
+go_repository(
+    name = "com_github_docker_distribution",
+    importpath = "github.com/docker/distribution",
+    sum = "h1:dvc1KSkIYTVjZgHf/CTC2diTYC8PzhaA5sFISRfNVrE=",
+    version = "v2.7.1-0.20190205005809-0d3efadf0154+incompatible",
+)
+
+go_repository(
+    name = "com_github_docker_go_units",
+    importpath = "github.com/docker/go-units",
+    sum = "h1:3uh0PgVws3nIA0Q+MwDC8yjEPf9zjRfZZWXZYDct3Tw=",
+    version = "v0.4.0",
+)
+
+go_repository(
+    name = "com_github_containerd_continuity",
+    importpath = "github.com/containerd/continuity",
+    sum = "h1:nXPkFq8X1a9ycY3GYQpFNxHh3j2JgY7zDZfq2EXMIzk=",
+    version = "v0.0.0-20200413184840-d3ef23f19fbb",
+)
+
+go_repository(
+    name = "com_github_opencontainers_go_digest",
+    importpath = "github.com/opencontainers/go-digest",
+    sum = "h1:WzifXhOVOEOuFYOJAW6aQqW0TooG2iki3E3Ii+WN7gQ=",
+    version = "v1.0.0-rc1",
+)
+
+go_repository(
+    name = "com_github_opencontainers_image_spec",
+    importpath = "github.com/opencontainers/image-spec",
+    sum = "h1:JMemWkRwHx4Zj+fVxWoMCFm/8sYGGrUVojFA6h/TRcI=",
+    version = "v1.0.1",
+)
+
+go_repository(
+    name = "com_github_opencontainers_runc",
+    importpath = "github.com/opencontainers/runc",
+    sum = "h1:GlxAyO6x8rfZYN9Tt0Kti5a/cP41iuiO2yYT0IJGY8Y=",
+    version = "v0.1.1",
+)
+
+go_repository(
+    name = "com_github_mitchellh_mapstructure",
+    importpath = "github.com/mitchellh/mapstructure",
+    sum = "h1:dxe5oCinTXiTIcfgmZecdCzPmAJKd46KsCWc35r0TV4=",
+    version = "v1.2.2",
+)
+
+go_repository(
+    name = "com_github_romnnn_flatbson",
+    importpath = "github.com/romnnn/flatbson",
+    sum = "h1:5m1VfuKcXWyl3TX6j5xjLdKpSkGlIUB4JRvt+S6/aSk=",
+    version = "v0.1.0",
+)
+
+go_repository(
+    name = "com_github_lestrrat_go_jwx",
+    importpath = "github.com/lestrrat-go/jwx",
+    sum = "h1:1neTPQvRiPRtQpU7QHEEG6dM8A1AFCgi1FGN/2VBucA=",
+    version = "v0.9.2",
+)

anubis/src/App.vue

@@ -13,6 +13,7 @@ import NprogressContainer from "vue-nprogress/src/NprogressContainer.vue";
 import { AuthModule } from "./store/modules/auth";
 import { AppModule } from "./store/modules/app";
 import { TrainDelayNotification } from "./generated/protobuf/models/events/TrainDelayNotification_pb";
+import { COOKIE_THEME } from "./constants";
 
 @Component({
   name: "App",
@@ -60,6 +61,12 @@ export default class App extends Vue {
   }
 
   created() {
+    let theme: number = parseInt(
+      (this.$cookies.get(COOKIE_THEME) ?? "").toString()
+    );
+    if (!isNaN(theme)) {
+      AppModule.setTheme(theme);
+    }
     this.axios.interceptors.response.use(undefined, err => {
       return new Promise((resolve, reject) => {
         if (err.status === 401 && err.config && !err.config.__isRetryRequest) {

anubis/src/components/AccountDropdown.vue

@@ -43,6 +43,7 @@
 <script lang="ts">
 import AccountDropdownElement from "../components/AccountDropdownElement.vue";
 import { Component, Prop, Vue } from "vue-property-decorator";
+import { AuthModule } from "../store/modules/auth";
 
 @Component({
   name: "AccountDropdown",
@@ -57,9 +58,7 @@ export default class AccountDropdown extends Vue {
   open: boolean = false;
 
   logout() {
-    this.$store.dispatch("AUTH_LOGOUT").then(() => {
-      this.$router.push("/login");
-    });
+    AuthModule.authLogout();
   }
 
   mounted() {}

anubis/src/components/Navbar.vue

@@ -246,7 +246,7 @@ import NotificationDropdownElement from "@/components/NotificationDropdownElemen
 import EmailDropdownElement from "@/components/EmailDropdownElement.vue";
 import AccountDropdown from "@/components/AccountDropdown.vue";
 import NavbarDropdown from "@/components/NavbarDropdown.vue";
-import { GrpcModule } from "../store/modules/grpc";
+import { ReplayerModule } from "../store/modules/replayer";
 import { AppModule } from "../store/modules/app";
 import axios from "axios";
 import BeatLoader from "vue-spinner/src/BeatLoader.vue";
@@ -323,27 +323,27 @@ export default class NavigationBar extends Vue {
   }
 
   get isReplaying() {
-    return GrpcModule.isReplaying;
+    return ReplayerModule.isReplaying;
   }
 
   get isLoading() {
     return AppModule.isLoading;
   }
 
   get replayStatus() {
-    return GrpcModule.replayStatus;
+    return ReplayerModule.replayStatus;
   }
 
   get replayingIds() {
-    return GrpcModule.replayingOptions?.getIdsList();
+    return ReplayerModule.replayingOptions?.getIdsList();
   }
 
   get replayingType() {
-    return GrpcModule.replayingOptions?.getType();
+    return ReplayerModule.replayingOptions?.getType();
   }
 
   get replayingSpeed() {
-    return GrpcModule.replayingOptions?.getSpeed();
+    return ReplayerModule.replayingOptions?.getSpeed();
   }
 
   get isConstantReplay(): boolean {
@@ -426,15 +426,15 @@ export default class NavigationBar extends Vue {
   }
 
   toggleReplay() {
-    GrpcModule.toggleReplayer(this.replayOptions);
+    ReplayerModule.toggleReplayer(this.replayOptions);
   }
 
   updateReplay() {
-    GrpcModule.setReplayOptions(this.replayOptions);
+    ReplayerModule.setReplayOptions(this.replayOptions);
   }
 
   resetReplay() {
-    GrpcModule.resetReplayer();
+    ReplayerModule.resetReplayer();
   }
 
   toggleSearch() {
@@ -457,7 +457,7 @@ export default class NavigationBar extends Vue {
 
   mounted(): void {
     this.updateTime();
-    GrpcModule.queryReplayer().then(() => {
+    ReplayerModule.queryReplayer().then(() => {
       if (this.replayingSpeed != undefined)
         this.replaySpeed = this.replayingSpeed?.getSpeed();
     });

anubis/src/components/TransportsTableView.vue

@@ -14,7 +14,7 @@
 <script lang="ts">
 import BasicTable from "../components/BasicTable.vue";
 import GridTable from "../components/GridTable.vue";
-import { GrpcModule } from "../store/modules/grpc";
+import { ReplayerModule } from "../store/modules/replayer";
 import { Component, Vue, Prop } from "vue-property-decorator";
 
 @Component({

anubis/src/main.ts

@@ -31,9 +31,8 @@ Vue.config.productionTip = false;
 // Set up progress bar
 const nprogress = new NProgress(options);
 
-/*
 // Set authentication token if available
-const authToken = localStorage.getItem("user-token");
+const authToken = Vue.cookies.get("user-token");
 if (authToken) {
   Vue.axios.defaults.headers.common["Authorization"] = authToken;
 }
@@ -55,8 +54,6 @@ router.beforeEach((to, from, next) => {
   }
 });
 
- */
-
 new Vue({
   nprogress,
   router,