.configx/demo_ssh_key

------BEGIN OPENSSH PRIVATE KEY-----
-b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAlwAAAAdzc2gtcn
-NhAAAAAwEAAQAAAIEA7Ct96yDKZ1toOjMigoUV+bmH/z7kSWwtyLgjEQzN0dDU88Lo0ebK
-Dj2fHbo1GZnAJg77qDqIGzWMiY8oOOfiZXpj8sPvDmVoSWyAwKZhzIHigiNY9y9nW38y28
-lUC/sRBe9NTRKKEyq2Nu3QAQ60kzI5cKuZzKslU7Cz+9f8iRsAAAIAKzE8bysxPG8AAAAH
-c3NoLXJzYQAAAIEA7Ct96yDKZ1toOjMigoUV+bmH/z7kSWwtyLgjEQzN0dDU88Lo0ebKDj
-2fHbo1GZnAJg77qDqIGzWMiY8oOOfiZXpj8sPvDmVoSWyAwKZhzIHigiNY9y9nW38y28lU
-C/sRBe9NTRKKEyq2Nu3QAQ60kzI5cKuZzKslU7Cz+9f8iRsAAAADAQABAAAAgB2FUjgR4T
-sKMf0UZzvpZtXQWy+MrPyAiTiNy9RVxWR0tinCM1gJgThGe507qWeJ0HrxZIOizWCZUPfg
-7SYv1hybtv7uHldg1FUAUZldtOPtyVwvWMMP0lLhYkfkxLHHx2ZzL3qnG//jvx4gIWcbxJ
-9C2+bDoxc/NSeo57jFHwABAAAAQCiaEiu5AAi1ZpotYpCEZXR+CgiRTDtwSOB4eM0d4rgx
-mfVdTtkQqLKhGVF6wryEwEQ6Jhz9KqE89L3HO+R3LxgAAABBAPdAheySXhXIj9/PRMW2h3
-a6f5DR2D2WqRdvOwIrVJli4+SzoPlDBg8ezOAQsIcz5dMqfLhB/Nd0KCXZ1Gi6+ZsAAABB
-APSGl65yhFZCCud8rmY5N/W9sszfi60lnMoaVo7EAv3ksDXqPWSR1R2fWxPDFp4i1SM1pv
-cI+MFN9JpfGgiDZoEAAAALdnNAYTQyMjlkNzU=
------END OPENSSH PRIVATE KEY-----

.configx/demo_ssh_key.pub

-ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAAAgQDsK33rIMpnW2g6MyKChRX5uYf/PuRJbC3IuCMRDM3R0NTzwujR5soOPZ8dujUZmcAmDvuoOogbNYyJjyg45+JlemPyw+8OZWhJbIDApmHMgeKCI1j3L2dbfzLbyVQL+xEF701NEooTKrY27dABDrSTMjlwq5nMqyVTsLP71/yJGw== vs@a4229d75

.configx/sshd_config

-
-AuthorizedKeysCommand /nix/store/w8vm09hri2zz7yacryzzzxvsapik4ps4-coreutils-9.1/bin/cat /home/vs/workspaces/oss/go-libs/job-queues/.devenv/chroot/home/demo/.ssh/authorized_keys
-AuthorizedKeysCommandUser nobody
-
-Match User root
-    ChrootDirectory /home/vs/workspaces/oss/go-libs/job-queues/.devenv/chroot
-    ForceCommand internal-sftp
-    PasswordAuthentication no
-    PermitTunnel no
-    AllowAgentForwarding no
-    AllowTcpForwarding no
-    X11Forwarding no
-    PermitRootLogin no
-    AllowUsers demo root

.configx/temp_ed25518_key

------BEGIN OPENSSH PRIVATE KEY-----
-b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAMwAAAAtzc2gtZW
-QyNTUxOQAAACBxagk6nB2R86bvLZ7aNKHsmMAVeU67fIo2Wdp+EymHTgAAAJBntrIpZ7ay
-KQAAAAtzc2gtZWQyNTUxOQAAACBxagk6nB2R86bvLZ7aNKHsmMAVeU67fIo2Wdp+EymHTg
-AAAEBPmQk0dpM/BVsTi3hfROLxOgq/bzv4Sef0PNoK9Ra2NnFqCTqcHZHzpu8tnto0oeyY
-wBV5Trt8ijZZ2n4TKYdOAAAAC3ZzQGE0MjI5ZDc1AQI=
------END OPENSSH PRIVATE KEY-----

.configx/temp_ed25518_key.pub

-ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIHFqCTqcHZHzpu8tnto0oeyYwBV5Trt8ijZZ2n4TKYdO vs@a4229d75

.configx/temp_rsa_key

------BEGIN OPENSSH PRIVATE KEY-----
-b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAABlwAAAAdzc2gtcn
-NhAAAAAwEAAQAAAYEAuTp14MpandyyftGinDQEIs7Pr88TeogFMSdoZm5AUbUliK9M6M7n
-QHQctTeMW0TelHlwVrZCwXcQn5sCpRaWE1AtEjPtZ1r6pD2HlpAkQfxMtP9TNJPwHpJ/1V
-uofvmu4adNxN6mZw6CH34vNJGgUuFNXwq6XtbrwM4TIacEu718oSf0oNOCECijZSsbSoBn
-ljsIbCcdqXClNs0pHq2lVPj0vdzGg4PQLkcRjLPoDgiQfwOxPmL/UCBraXHoLXIyz4sNfs
-4ZQXjfLYfwgHiV145oo/kD4dgmqCfo4HOipOQlvIYs4iRHyjyvQqiirTs2h3G8ZXPBelxW
-DxEsKLfNX4XbNM6yPvYLoZadSbV2gJC/O9Wv0DLJbhucjq9X5gMMVsjgccctfnvwEZPU3s
-lZLU4ntENh5jIW8w5ONHavOX23+b2MrCfP9OHB6gnNAuo7wPfWPctapcdhQ5kWUBH+G+bU
-Epa6EAyDke9nhIy8eu+T12MrmccQFZCGKBpuR9mLAAAFgHop0+x6KdPsAAAAB3NzaC1yc2
-EAAAGBALk6deDKWp3csn7Ropw0BCLOz6/PE3qIBTEnaGZuQFG1JYivTOjO50B0HLU3jFtE
-3pR5cFa2QsF3EJ+bAqUWlhNQLRIz7Wda+qQ9h5aQJEH8TLT/UzST8B6Sf9VbqH75ruGnTc
-TepmcOgh9+LzSRoFLhTV8Kul7W68DOEyGnBLu9fKEn9KDTghAoo2UrG0qAZ5Y7CGwnHalw
-pTbNKR6tpVT49L3cxoOD0C5HEYyz6A4IkH8DsT5i/1Aga2lx6C1yMs+LDX7OGUF43y2H8I
-B4ldeOaKP5A+HYJqgn6OBzoqTkJbyGLOIkR8o8r0Kooq07NodxvGVzwXpcVg8RLCi3zV+F
-2zTOsj72C6GWnUm1doCQvzvVr9AyyW4bnI6vV+YDDFbI4HHHLX578BGT1N7JWS1OJ7RDYe
-YyFvMOTjR2rzl9t/m9jKwnz/ThweoJzQLqO8D31j3LWqXHYUOZFlAR/hvm1BKWuhAMg5Hv
-Z4SMvHrvk9djK5nHEBWQhigabkfZiwAAAAMBAAEAAAGACZTKkCwnb88AtKqnXKkcJajI+X
-EestHiYt6E+fduAEv8ewuGUOyS7bST35PWAMqZMNjvRKz82wELrRXZlyyJ6snU6wIgn54H
-JQPBxboDBh7E4P/sD+YvH4W4cxLgrmC/+RAsZ6iUtvP7KyHd0zxNLLxWwjnN1iYL39dJCg
-6XohZ1IejtMHyAV9GiUhNewAXQVecL0nxbfm5DPYhzPhEBYlnWXxPSeO8Sj7JBaCPONxue
-TdOlEXMRfdWPeM7ZkbA8dg4Khl3uAR4hFKhW6QfsI/uBlgKdeuDKzcKsAAQHfa7dmqIO7Q
-dsOa41DnyQEw1X9H6p9CY+G+Lc+jub4EKgIuYNGMA2+QLSujsooq4QaI6rjiyb/Hr1xPjb
-E4GOzMmM+F/6PjswhGFImZ32mYBzhBlZxaS7x+01mAG4PLiy/sOfzh1sLjTnIgxCuo2HU1
-S70VvBTOSmfCHu8x1K583fkt7iaMoN3vTDookkD758D+MqH9fdCRLbuz6LBuy3D+dxAAAA
-wF0TZH/yMLYLY8luQ2AUTTV3GNHF2ObWJP34HVi/0AY2Yp8ywMk0K5Tazc3F1X91KDWjd2
-3JPrP8m7ESJYb6WA/vJEFXO1g4EEP8gwXrBWIKa69Dj8Q36MhQQk4ClBZKFCjVMFgbW6bs
-Jm5Ft8rjoRG1ULgaHum60yJsI0e2qMZNV0Pk/KL+IhLARSYcgtYHxXt7UgQCEea0F7rKeS
-yU2Jwx9bNd62w+qTfsKEpguBIOE69J9OsXTRLyvOT4SRaarAAAAMEA5Hba3sZZ0hz8H2bt
-fxAd88SNjNCXtOxD8a4A2Y65ku5DVw9EcttZadw8YUfKOr6YPZlBGd19tv27us3Re9C67m
-VGjobdUbCWtAZ2orre7XIBVrPmFXDWJ60ABU9/O2UhABwtx4X1XfKySPETJ4ZNpZ1AMRpA
-2S0RR2chTbBVTnDQ3otHx9cP6IQhTwMLqfujeZXwFUJI/5v/5yKj1fYUDHc1elNUXugCbK
-2qeLmLQgry0XsmfPsuKRbxduSbVchXAAAAwQDPjZWFQ2ColxOg00M96MHnI0y0EL+8FGLl
-yfi9VtN+hqCVhK9p0kalqwDMad112nwELEVQtQ5JtwrqpasI1/BYMVh6YdSIPvtrFGPVJF
-iMF1UqcYVhbQ0bVzKiszFyjq7uZAEvqMVf/BpfxtZL8xJvnIZSysb8VM2yWa1lkkQ1w8KT
-efy58cz3Ha6XFIImojyYXjl6s2etsIJbsHEvl1rTSl5uPcJZfu2jw24j8ux5cT1D+0koSG
-xpqPwJ4sHVB+0AAAALdnNAYTQyMjlkNzU=
------END OPENSSH PRIVATE KEY-----

.configx/temp_rsa_key.pub

-ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABgQC5OnXgylqd3LJ+0aKcNAQizs+vzxN6iAUxJ2hmbkBRtSWIr0zozudAdBy1N4xbRN6UeXBWtkLBdxCfmwKlFpYTUC0SM+1nWvqkPYeWkCRB/Ey0/1M0k/Aekn/VW6h++a7hp03E3qZnDoIffi80kaBS4U1fCrpe1uvAzhMhpwS7vXyhJ/Sg04IQKKNlKxtKgGeWOwhsJx2pcKU2zSkeraVU+PS93MaDg9AuRxGMs+gOCJB/A7E+Yv9QIGtpcegtcjLPiw1+zhlBeN8th/CAeJXXjmij+QPh2CaoJ+jgc6Kk5CW8hiziJEfKPK9CqKKtOzaHcbxlc8F6XFYPESwot81fhds0zrI+9guhlp1JtXaAkL871a/QMsluG5yOr1fmAwxWyOBxxy1+e/ARk9TeyVktTie0Q2HmMhbzDk40dq85fbf5vYysJ8/04cHqCc0C6jvA99Y9y1qlx2FDmRZQEf4b5tQSlroQDIOR72eEjLx675PXYyuZxxAVkIYoGm5H2Ys= vs@a4229d75

.gitlab-ci.yml

@@ -43,10 +43,6 @@ test:
     - key: nixos
       paths:
         - /nix/store
-  
-  artifacts:
-    paths:
-      - dist
 
 deploy:
   stage: deploy

.idea/workspace.xml

@@ -5,12 +5,8 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="9979eb22-471e-4f2f-b624-fd3edb5e8c6e" name="Changes" comment="">
-      <change beforePath="$PROJECT_DIR$/.gitlab-ci.yml" beforeDir="false" afterPath="$PROJECT_DIR$/.gitlab-ci.yml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/flake.nix" beforeDir="false" afterPath="$PROJECT_DIR$/flake.nix" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/nix/scripts/cleanup.nix" beforeDir="false" afterPath="$PROJECT_DIR$/nix/scripts/clean-up.nix" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/nix/scripts/go-task.nix" beforeDir="false" afterPath="$PROJECT_DIR$/nix/scripts/go-task.nix" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/nix/scripts/run-extended-tests.nix" beforeDir="false" afterPath="$PROJECT_DIR$/nix/scripts/run-extended-tests.nix" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/manager_test.go" beforeDir="false" afterPath="$PROJECT_DIR$/manager_test.go" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -49,6 +45,7 @@
   "keyToString": {
     "DefaultGoTemplateProperty": "Go File",
     "Go Test.TestDummyRunnable in gitlab.schukai.com/oss/libraries/go/services/job-queues.executor": "Debug",
+    "Go Test.TestManagerEventHandling in gitlab.schukai.com/oss/libraries/go/services/job-queues.executor": "Debug",
     "Go Test.TestResetStats in gitlab.schukai.com/oss/libraries/go/services/job-queues.executor": "Debug",
     "Go Test.TestRoundTrip in gitlab.schukai.com/oss/libraries/go/services/job-queues.executor": "Debug",
     "Go Test.TestScheduleJob in gitlab.schukai.com/oss/libraries/go/services/job-queues.executor": "Debug",
@@ -84,7 +81,7 @@
       <recent name="$PROJECT_DIR$/.back" />
     </key>
   </component>
-  <component name="RunManager" selected="Go Test.TestRoundTrip in gitlab.schukai.com/oss/libraries/go/services/job-queues">
+  <component name="RunManager" selected="Go Test.TestManagerEventHandling in gitlab.schukai.com/oss/libraries/go/services/job-queues">
     <configuration default="true" type="GoApplicationRunConfiguration" factoryName="Go Application">
       <module name="job-queues" />
       <working_directory value="$PROJECT_DIR$" />
@@ -94,7 +91,7 @@
       <filePath value="$PROJECT_DIR$" />
       <method v="2" />
     </configuration>
-    <configuration name="TestDummyRunnable in gitlab.schukai.com/oss/libraries/go/services/job-queues" type="GoTestRunConfiguration" factoryName="Go Test" temporary="true" nameIsGenerated="true">
+    <configuration name="TestManagerEventHandling in gitlab.schukai.com/oss/libraries/go/services/job-queues" type="GoTestRunConfiguration" factoryName="Go Test" temporary="true" nameIsGenerated="true">
       <module name="job-queues" />
       <working_directory value="$PROJECT_DIR$" />
       <kind value="PACKAGE" />
@@ -102,7 +99,7 @@
       <directory value="$PROJECT_DIR$" />
       <filePath value="$PROJECT_DIR$" />
       <framework value="gotest" />
-      <pattern value="^\QTestDummyRunnable\E$" />
+      <pattern value="^\QTestManagerEventHandling\E$" />
       <method v="2" />
     </configuration>
     <configuration name="TestRoundTrip in gitlab.schukai.com/oss/libraries/go/services/job-queues" type="GoTestRunConfiguration" factoryName="Go Test" temporary="true" nameIsGenerated="true">
@@ -161,11 +158,11 @@
     </configuration>
     <recent_temporary>
       <list>
+        <item itemvalue="Go Test.TestManagerEventHandling in gitlab.schukai.com/oss/libraries/go/services/job-queues" />
         <item itemvalue="Go Test.TestRoundTrip in gitlab.schukai.com/oss/libraries/go/services/job-queues" />
         <item itemvalue="Go Test.TestWriteToDB4 in gitlab.schukai.com/oss/libraries/go/services/job-queues" />
         <item itemvalue="Go Test.TestWriteToDB1 in gitlab.schukai.com/oss/libraries/go/services/job-queues" />
         <item itemvalue="Go Test.TestWriteToDB2 in gitlab.schukai.com/oss/libraries/go/services/job-queues" />
-        <item itemvalue="Go Test.TestDummyRunnable in gitlab.schukai.com/oss/libraries/go/services/job-queues" />
       </list>
     </recent_temporary>
   </component>

database-1_test.go

@@ -17,7 +17,7 @@ func TestWriteToDB1(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-2_test.go

@@ -16,7 +16,7 @@ import (
 func TestWriteToDB2(t *testing.T) {
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-3_test.go

@@ -16,7 +16,7 @@ func TestWriteToDB3(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-4_test.go

@@ -14,7 +14,7 @@ func TestWriteToDB4(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-5_test.go

@@ -13,7 +13,7 @@ func TestWriteToDB5(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-6_test.go

@@ -25,7 +25,7 @@ func TestWriteToDB6(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-7_test.go

@@ -13,7 +13,7 @@ import (
 func TestCreateOrUpdateJob(t *testing.T) {
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database-8_test.go

@@ -14,7 +14,7 @@ import (
 func TestUpdateJob(t *testing.T) {
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()
@@ -53,7 +53,7 @@ func TestCheckAndSaveOrUpdate(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

database_test.go

@@ -14,7 +14,7 @@ import (
 func TestDeleteJob(t *testing.T) {
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()
@@ -57,7 +57,7 @@ func TestDeleteJob(t *testing.T) {
 func TestResetLogs(t *testing.T) {
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()
@@ -109,7 +109,7 @@ func TestResetLogs(t *testing.T) {
 func TestResetStats(t *testing.T) {
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()

flake.nix

@@ -23,7 +23,7 @@
       script-run-ci-tests = pkgs'.callPackage ./nix/scripts/run-ci-tests.nix {};
       script-check-code = pkgs'.callPackage ./nix/scripts/check-code.nix {};
       script-build-cover-report = pkgs'.callPackage ./nix/scripts/build-cover-report.nix {};
-      
+
       script-clean-up = pkgs'.callPackage ./nix/scripts/clean-up.nix {};
       script-deploy = pkgs'.callPackage ./nix/scripts/deploy.nix {};
 
@@ -41,7 +41,7 @@
               script-check-code
               script-build-cover-report
               script-task
-              
+
               script-clean-up
               script-deploy
 

job-syncer_test.go

@@ -17,7 +17,7 @@ func TestSaveJobWithSQLite(t *testing.T) {
 
 	gormDB, err := gorm.Open(sqlite.Open("file:unique_id?mode=memory&cache=shared"), &gorm.Config{})
 	if err != nil {
-		t.Fatalf("a error occurred while opening the database: %v", err)
+		t.Fatalf("an error occurred while opening the database: %v", err)
 	}
 	t.Cleanup(func() {
 		sqlDB, err := gormDB.DB()