add status to assignment, assignment deactivator => assignment updater

Author: edshadi

.idea/.gitignore

@@ -4,7 +4,7 @@ CREATE TABLE `assignments` (
   `task_id` int(10) unsigned NOT NULL,
   `response_id` int(10) unsigned DEFAULT NULL,
   `worker_id` int(10) unsigned NOT NULL,
-  `active` tinyint(1) NOT NULL DEFAULT '1',
+  `status` varchar(20) NOT NULL DEFAULT 'active',
   `assigned_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   `expires_at` timestamp NULL DEFAULT NULL,
   PRIMARY KEY (`id`),

.idea/assignment.iml

@@ -1,7 +1,7 @@
 CREATE TABLE `whitelists` (
   `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
-  `job_id` int(11) unsigned NOT NULL,
   `worker_id` int(11) unsigned NOT NULL,
+  `job_id` int(11) unsigned NOT NULL,
   PRIMARY KEY (`id`),
   UNIQUE KEY `job_worker` (`job_id`,`worker_id`)
 )

.idea/misc.xml

@@ -1,4 +1,4 @@
-package assignmentdeactivator
+package assignmentupdater
 
 import (
 	"context"
@@ -9,12 +9,12 @@ import (
 	"github.com/go-kit/kit/endpoint"
 )
 
-func makeAssignmentDeactivatorEndpoint(svc service.AssignmentService) endpoint.Endpoint {
+func makeAssignmentUpdaterEndpoint(svc service.AssignmentService) endpoint.Endpoint {
 	return func(ctx context.Context, request interface{}) (interface{}, error) {
 		data, _ := authentication.ParseAuthData(ctx)
 		svc.SetAuthData(data)
 		req := request.(AssignmentRequest)
-		p, err := svc.DeactivateAssignment(req.WorkerID, req.JobID)
+		p, err := svc.UpdateAssignment(req.WorkerID, req.JobID, req.Status)
 		if err != nil {
 			return AssignmentResponse{p}, errorResponse(err)
 		}
@@ -29,8 +29,9 @@ func errorResponse(err error) *apierror.APIError {
 type AssignmentRequest struct {
 	WorkerID uint64 `json:"worker_id"`
 	JobID    uint64 `json:"job_id"`
+	Status   string `json:"status"`
 }
 
 type AssignmentResponse struct {
-	Deactivated bool `json:"deactivated"`
+	Updated bool `json:"updated"`
 }