| 22 | } |
| 23 | |
| 24 | func (self *PlexpyRPC) Install(opts *PlexpyOpts, job *jobs.Job) error { |
| 25 | *job = *jobs.New(opts) |
| 26 | log.Debugln("Plexpy options:", opts) |
| 27 | go func() { |
| 28 | err := self.base.Install(opts) |
| 29 | job.Options = *opts |
| 30 | |
| 31 | if err != nil { |
| 32 | log.Debugln("Plexpy installation received an error:", err) |
| 33 | job.ErrorString = err.Error() |
| 34 | job.Error = err |
| 35 | job.Status = jobs.FAILED |
| 36 | } else { |
| 37 | log.Infoln("Plexpy installation completed") |
| 38 | job.Status = jobs.FINISHED |
| 39 | } |
| 40 | |
| 41 | jobs.Storage.Set(job.Id, job) |
| 42 | }() |
| 43 | |
| 44 | return nil |
| 45 | } |