Skip to content

Commit

Permalink
YOLO removing the old code
Browse files Browse the repository at this point in the history
  • Loading branch information
@COMTOP1
COMTOP1 committed Mar 1, 2024
1 parent 0ee30b8 commit 1cb2eb2
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 230 deletions.
109 changes: 0 additions & 109 deletions server/views/start.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,115 +27,6 @@ func (v *Views) StartFunc(c echo.Context) error {
return c.JSON(http.StatusOK, response)
}

//formValues := v.startSaveValidationHelper(c, startValidation)
//if formValues.Error != nil {
// log.Printf("invalid form input: %+v", formValues.Error)
// response.Error = fmt.Sprintf("invalid form input: %+v", formValues.Error)
// return c.JSON(http.StatusOK, response)
//}
//
//transporter := commonTransporter.Transporter{
// Action: action.startValidation,
// Unique: unique,
//}
//
//fStart := commonTransporter.ForwarderStart{
// StreamIn: formValues.Input,
// WebsiteOut: formValues.WebsiteOut,
//}
//
//rStart := commonTransporter.RecorderStart{
// StreamIn: formValues.Input,
// PathOut: formValues.SavePath,
//}
//
//fStart.Streams = formValues.Streams
//
//var wg sync.WaitGroup
//wg.Add(2)
//var errorMessages []string
//go func() {
// defer wg.Done()
// if formValues.RecordCheckbox {
// recorderTransporter := transporter
// recorderTransporter.Payload = rStart
// var wsResponse commonTransporter.ResponseTransporter
// wsResponse, err = v.wsHelper(server.Recorder, recorderTransporter)
// if err != nil {
// log.Printf("failed sending to Recorder for start: %+v", err)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Recorder for start: %+v", err))
// return
// }
// if wsResponse.Status == wsMessages.Error {
// log.Printf("failed sending to Recorder for start: %s", wsResponse.Payload)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Recorder for start: %s", wsResponse.Payload))
// return
// }
// if wsResponse.Status != wsMessages.Okay {
// log.Printf("invalid response from Recorder for start: %s", wsResponse.Status)
// errorMessages = append(errorMessages, fmt.Sprintf("invalid response from Recorder for start: %s", wsResponse.Status))
// return
// }
// }
//}()
//go func() {
// defer wg.Done()
// forwarderTransporter := transporter
// forwarderTransporter.Payload = fStart
// var wsResponse commonTransporter.ResponseTransporter
// wsResponse, err = v.wsHelper(server.Forwarder, forwarderTransporter)
// if err != nil {
// log.Printf("failed sending to Forwarder for start: %+v", err)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Forwarder for start: %+v", err))
// return
// }
// if wsResponse.Status == wsMessages.Error {
// log.Printf("failed sending to Forwarder for start: %s", response)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Forwarder for start: %s", response))
// return
// }
// if wsResponse.Status != wsMessages.Okay {
// log.Printf("invalid response from Forwarder for start: %s", response)
// errorMessages = append(errorMessages, fmt.Sprintf("invalid response from Forwarder for start: %s", response))
// return
// }
//}()
//wg.Wait()
//
//if len(errorMessages) == 0 {
// err = v.HandleTXLight(v.conf.TransmissionLight, tx.TransmissionOn)
// if err != nil {
// log.Printf("failed to turn transmission light on: %+v, ignoring and continuing", err)
// }
//
// var s *storage.Stream
// s, err = v.store.AddStream(&storage.Stream{
// Stream: unique,
// Input: formValues.Input,
// Recording: rStart.PathOut,
// Website: fStart.WebsiteOut,
// Streams: formValues.Streams,
// })
// if err != nil {
// log.Printf("invalid response from Forwarder for start: %s", response)
// errorMessages = append(errorMessages, fmt.Sprintf("invalid response from Forwarder for start: %s", response))
// response.Error = strings.Join(errorMessages, ",")
// return c.JSON(http.StatusOK, response)
// }
//
// if s == nil {
// log.Printf("failed to add stream, data is empty")
// errorMessages = append(errorMessages, "failed to add stream, data is empty")
// response.Error = strings.Join(errorMessages, ",")
// return c.JSON(http.StatusOK, response)
// }
//
// log.Printf("started stream: %s", unique)
//
// response.Unique = unique
// return c.JSON(http.StatusOK, response)
//}

err = v.startingWSHelper(c, unique, nonStoredStart)
if err != nil {
log.Printf("failed to start: %+v", err)
Expand Down
121 changes: 0 additions & 121 deletions server/views/startUnique.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -40,127 +40,6 @@ func (v *Views) StartUniqueFunc(c echo.Context) error {
return c.JSON(http.StatusOK, response)
}

//formValues := v.startSaveValidationHelper(c, startUniqueValidation)
//if formValues.Error != nil {
// log.Printf("invalid form input: %+v", formValues.Error)
// response.Error = fmt.Sprintf("invalid form input: %+v", formValues.Error)
// return c.JSON(http.StatusOK, response)
//}
//
//transporter := commonTransporter.Transporter{
// Action: action.startValidation,
// Unique: unique,
//}
//
//fStart := commonTransporter.ForwarderStart{
// StreamIn: formValues.Input,
// WebsiteOut: formValues.WebsiteOut,
//}
//
//rStart := commonTransporter.RecorderStart{
// StreamIn: formValues.Input,
// PathOut: formValues.SavePath,
//}
//
//fStart.Streams = formValues.Streams
//
//var wg sync.WaitGroup
//wg.Add(2)
//var errorMessages []string
//go func() {
// defer wg.Done()
// if formValues.RecordCheckbox {
// recorderTransporter := transporter
// recorderTransporter.Payload = rStart
// var wsResponse commonTransporter.ResponseTransporter
// wsResponse, err = v.wsHelper(server.Recorder, recorderTransporter)
// if err != nil {
// log.Printf("failed sending to Recorder for start: %+v", err)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Recorder for start: %+v", err))
// return
// }
// if wsResponse.Status == wsMessages.Error {
// log.Printf("failed sending to Recorder for start: %s", wsResponse.Payload)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Recorder for start: %s", wsResponse.Payload))
// return
// }
// if wsResponse.Status != wsMessages.Okay {
// log.Printf("invalid response from Recorder for start: %s", wsResponse.Status)
// errorMessages = append(errorMessages, fmt.Sprintf("invalid response from Recorder for start: %s", wsResponse.Status))
// return
// }
// }
//}()
//go func() {
// defer wg.Done()
// forwarderTransporter := transporter
// forwarderTransporter.Payload = fStart
// var wsResponse commonTransporter.ResponseTransporter
// wsResponse, err = v.wsHelper(server.Forwarder, forwarderTransporter)
// if err != nil {
// log.Printf("failed sending to Forwarder for start: %+v", err)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Forwarder for start: %+v", err))
// return
// }
// if wsResponse.Status == wsMessages.Error {
// log.Printf("failed sending to Forwarder for start: %s", response)
// errorMessages = append(errorMessages, fmt.Sprintf("failed sending to Forwarder for start: %s", response))
// return
// }
// if wsResponse.Status != wsMessages.Okay {
// log.Printf("invalid response from Forwarder for start: %s", response)
// errorMessages = append(errorMessages, fmt.Sprintf("invalid response from Forwarder for start: %s", response))
// return
// }
//}()
//wg.Wait()
//
//if len(errorMessages) == 0 {
// err = v.HandleTXLight(v.conf.TransmissionLight, tx.TransmissionOn)
// if err != nil {
// log.Printf("failed to turn transmission light on: %+v, ignoring and continuing", err)
// }
//
// var s *storage.Stream
// s, err = v.store.AddStream(&storage.Stream{
// Stream: unique,
// Input: formValues.Input,
// Recording: rStart.PathOut,
// Website: fStart.WebsiteOut,
// Streams: formValues.Streams,
// })
// if err != nil {
// log.Printf("invalid response from Forwarder for start: %s", response)
// errorMessages = append(errorMessages, fmt.Sprintf("invalid response from Forwarder for start: %s", response))
// response.Error = strings.Join(errorMessages, ",")
// return c.JSON(http.StatusOK, response)
// }
//
// if s == nil {
// log.Printf("failed to add stream, data is empty")
// errorMessages = append(errorMessages, "failed to add stream, data is empty")
// response.Error = strings.Join(errorMessages, ",")
// return c.JSON(http.StatusOK, response)
// }
//
// err = v.store.DeleteStored(unique)
// if err != nil {
// log.Printf("failed to delete stored: %+v, unique: %s", err, unique)
// response.Error = fmt.Sprintf("failed to delete stored: %+v, unique: %s", err, unique)
// return c.JSON(http.StatusOK, response)
// }
//
// log.Printf("started stream: %s", unique)
//
// response.Unique = unique
// return c.JSON(http.StatusOK, response)
//}
//
//errMsg := strings.Join(errorMessages, ",")
//log.Printf("failed to start: %+v", errMsg)
//response.Error = fmt.Sprintf("failed to start: %+v", errMsg)
//return c.JSON(http.StatusOK, response)

err = v.startingWSHelper(c, unique, storedStart)
if err != nil {
log.Printf("failed to start: %+v", err)
Expand Down

0 comments on commit 1cb2eb2

Please sign in to comment.