Goxfer

goxfer.go

import (
  "fmt"
  "strconv"
  "sync"
)

type Transaction struct {
  Date string
  Account string
  Description string
  Amount float64
  Tags []string
}

func addTransaction(transaction Transaction, token string) error {
  // @todo: TBD
}

func main() {
  fmt.Println("Pushing transactions on Buxfer...")

  transactionAddedCounter := 0
  transactionNotAddedCounter := 0
  wg := &sync.WaitGroup{}
  for index, bulk := range bulks {
    fmt.Println("Pushing bulk #", index)

    wg.Add(len(bulk))
    for _, transaction := range bulk {
      // going parallel
      go func(transaction Transaction) {
        fmt.Println("Pushing transaction:", transaction)

        if err := addTransaction(transaction, token); err != nil {
          transactionNotAddedCounter++
          fmt.Println(err)
        } else {
          transactionAddedCounter++
        }

        wg.Done()
      }(transaction)
    }

    // wait the end of each request of the current bulk
    wg.Wait()
  }

  fmt.Println("Transactions succeded #", strconv.Itoa(transactionAddedCounter))
  fmt.Println("Transactions failed #", strconv.Itoa(transactionNotAddedCounter))
}