+ assertions.Equal(jobInfo, allJobs["type1"]["job1"])
+}
+
+func TestAddJobWhenTypeIsNotSupported_shouldReturnError(t *testing.T) {
+ assertions := require.New(t)
+ jobInfo := JobInfo{
+ InfoTypeIdentity: "type1",
+ }
+
+ err := AddJob(jobInfo)
+ assertions.NotNil(err)
+ assertions.Equal("type not supported: type1", err.Error())
+}
+
+func TestAddJobWhenJobIdMissing_shouldReturnError(t *testing.T) {
+ assertions := require.New(t)
+ allJobs["type1"] = make(map[string]JobInfo)
+ t.Cleanup(func() {
+ clearAll()
+ })
+ jobInfo := JobInfo{
+ InfoTypeIdentity: "type1",
+ }
+
+ err := AddJob(jobInfo)
+ assertions.NotNil(err)
+ assertions.Equal("missing required job identity: { type1}", err.Error())
+}
+
+func TestAddJobWhenTargetUriMissing_shouldReturnError(t *testing.T) {
+ assertions := require.New(t)
+ allJobs["type1"] = make(map[string]JobInfo)
+ jobInfo := JobInfo{
+ InfoTypeIdentity: "type1",
+ InfoJobIdentity: "job1",
+ }
+
+ err := AddJob(jobInfo)
+ assertions.NotNil(err)
+ assertions.Equal("missing required target URI: { job1 type1}", err.Error())
+ clearAll()