1 files changed, 79 insertions, 0 deletions
diff --git a/core/job/job.go b/core/job/job.go
new file mode 100644
index 0000000..9cfc0ed
--- /dev/null
+++ b/core/job/job.go
@@ -0,0 +1,79 @@
+package job
+
+import (
+	"github.com/isacikgoz/gitbatch/core/command"
+	"github.com/isacikgoz/gitbatch/core/git"
+)
+
+// Job relates the type of the operation and the entity
+type Job struct {
+	// JobType is to select operation type that will be applied to repository
+	JobType JobType
+	// Repository points to the repository that will be used for operation
+	Repository *git.Repository
+	// Options is a placeholder for operation options
+	Options interface{}
+}
+
+// JobType is the a git operation supported
+type JobType string
+
+const (
+	// FetchJob is wrapper of git fetch command
+	FetchJob JobType = "fetch"
+
+	// PullJob is wrapper of git pull command
+	PullJob JobType = "pull"
+
+	// MergeJob is wrapper of git merge command
+	MergeJob JobType = "merge"
+)
+
+// starts the job
+func (j *Job) start() error {
+	j.Repository.SetWorkStatus(git.Working)
+	// TODO: Handle errors?
+	// TOOD: Better implementation required
+	switch mode := j.JobType; mode {
+	case FetchJob:
+		var opts command.FetchOptions
+		if j.Options != nil {
+			opts = j.Options.(command.FetchOptions)
+		} else {
+			opts = command.FetchOptions{
+				RemoteName: j.Repository.State.Remote.Name,
+			}
+		}
+		if err := command.Fetch(j.Repository, opts); err != nil {
+			j.Repository.SetWorkStatus(git.Fail)
+			j.Repository.State.Message = err.Error()
+			return err
+		}
+	case PullJob:
+		var opts command.PullOptions
+		if j.Options != nil {
+			opts = j.Options.(command.PullOptions)
+		} else {
+			opts = command.PullOptions{
+				RemoteName: j.Repository.State.Remote.Name,
+			}
+		}
+		if err := command.Pull(j.Repository, opts); err != nil {
+			j.Repository.SetWorkStatus(git.Fail)
+			j.Repository.State.Message = err.Error()
+			return err
+		}
+	case MergeJob:
+		if err := command.Merge(j.Repository, command.MergeOptions{
+			BranchName: j.Repository.State.Remote.Branch.Name,
+		}); err != nil {
+			j.Repository.SetWorkStatus(git.Fail)
+			j.Repository.State.Message = err.Error()
+			return nil
+		}
+	default:
+		j.Repository.SetWorkStatus(git.Available)
+		return nil
+	}
+	return nil
+}