( ext ExternalTask, srcCfg SourceConfig, state *SyncState, existingIDs []string, now time.Time, )
| 113 | } |
| 114 | |
| 115 | func (e *Engine) syncTask( |
| 116 | ext ExternalTask, |
| 117 | srcCfg SourceConfig, |
| 118 | state *SyncState, |
| 119 | existingIDs []string, |
| 120 | now time.Time, |
| 121 | ) (SyncAction, error) { |
| 122 | mapped := MapExternalTask(ext, srcCfg.FieldMap) |
| 123 | extHash := HashExternalTask(ext) |
| 124 | outputDir := srcCfg.OutputDir |
| 125 | |
| 126 | ts, exists := state.Tasks[ext.ExternalID] |
| 127 | |
| 128 | if !exists { |
| 129 | return e.createTask(ext, mapped, extHash, outputDir, srcCfg.Name, state, existingIDs, now) |
| 130 | } |
| 131 | |
| 132 | return e.updateTask(ext, mapped, extHash, ts, state, now) |
| 133 | } |
| 134 | |
| 135 | func (e *Engine) createTask( |
| 136 | ext ExternalTask, |
no test coverage detected