Merge 2dad5bc into 27713b1

recordadderapi.go

@@ -25,3 +25,9 @@ func (s *Server) AddRecord(ctx context.Context, req *pb.AddRecordRequest) (*pb.A
 	err = s.KSclient.Save(ctx, QUEUE, queue)
 	return &pb.AddRecordResponse{ExpectedAdditionDate: time.Now().Add(time.Hour * time.Duration((24 * len(queue.Requests)))).Unix()}, err
 }
+
+// Test test function
+func (s *Server) Test(ctx context.Context, req *pb.AddRecordRequest) (*pb.AddRecordResponse, error) {
+	time.Sleep(time.Minute)
+	return nil, nil
+}

recordadderapi_test.go

@@ -15,6 +15,7 @@ func InitTestServer() *Server {
 	s := Init()
 	s.SkipLog = true
 	s.GoServer.KSclient = *keystoreclient.GetTestClient(".test")
+	s.GoServer.KSclient.Save(context.Background(), QUEUE, &pb.Queue{})
 	return s
 }
 
@@ -23,7 +24,7 @@ func TestAddRequest(t *testing.T) {
 
 	val, err := s.AddRecord(context.Background(), &pb.AddRecordRequest{})
 	if err != nil {
-		t.Errorf("Add Record failed: %v", err)
+		t.Fatalf("Add Record failed: %v", err)
 	}
 
 	if time.Now().After(time.Unix(val.ExpectedAdditionDate, 0)) {
@@ -40,3 +41,8 @@ func TestAddRequestFail(t *testing.T) {
 		t.Errorf("Add Record with failing read did not fail: %v", val)
 	}
 }
+
+func TestCallTest(t *testing.T) {
+	s := InitTestServer()
+	s.Test(context.Background(), &pb.AddRecordRequest{})
+}

recordadderutils_test.go

@@ -17,6 +17,7 @@ func InitTest() *Server {
 	s.rc = &testCollection{}
 	s.SkipLog = true
 	s.GoServer.KSclient = *keystoreclient.GetTestClient("./testing")
+	s.GoServer.KSclient.Save(context.Background(), QUEUE, &pb.Queue{})
 	return s
 }