timer_test.go

package timer

import (
	"context"
	//"encoding/json"
	//"testing"
	//"time"
	"io/ioutil"

	"github.com/TIBCOSoftware/flogo-lib/core/action"
	//"github.com/TIBCOSoftware/flogo-lib/core/trigger"
	"encoding/json"
	"github.com/TIBCOSoftware/flogo-lib/core/trigger"
	"testing"
)

var jsonTestMetadata = getTestJsonMetadata()

func getTestJsonMetadata() string {
	jsonMetadataBytes, err := ioutil.ReadFile("trigger.json")
	if err != nil {
		panic("No Json Metadata found for trigger.json path")
	}
	return string(jsonMetadataBytes)
}

const testConfig3 string = `{
  "name": "flogo-timer",
  "settings": {
  },
  "endpoints": [
    {
      "flowURI": "local://testFlow2",
      "settings": {
        "repeating": "false"
      }
    }
  ]
}`

const testConfig string = `{
  "name": "flogo-timer",
  "settings": {
  },
  "endpoints": [
    {
      "flowURI": "local://testFlow2",
      "settings": {
        "repeating": "false",
        "startDate" : "2016-05-03T19:25:00Z-04:00"
      }
    }
  ]
}`

const testConfig2 string = `{
  "name": "flogo-timer",
  "settings": {
  },
  "endpoints": [
    {
      "flowURI": "local://testFlow2",
      "settings": {
      	"notImmediate": "false",
        "repeating": "true",
        "seconds": "5"
      }
    }
  ]
}`

const testConfig4 string = `{
  "name": "flogo-timer",
  "settings": {
  },
  "endpoints": [
    {
      "flowURI": "local://testFlow",
      "settings": {
        "repeating": "false",
        "startDate" : "05/01/2016, 12:25:01"
      }
    },
    {
      "flowURI": "local://testFlow2",
      "settings": {
        "repeating": "true",
        "startDate" : "05/01/2016, 12:25:01",
        "hours": "24"
      }
    },
    {
      "flowURI": "local://testFlow3",
      "settings": {
        "repeating": "true",
        "startDate" : "05/01/2016, 12:25:01",
        "minutes": "60"
      }
    },
    {
      "flowURI": "local://testFlow3",
      "settings": {
        "repeating": "true",
        "startDate" : "05/01/2016, 12:25:01",
        "seconds": "30"
      }
    }
  ]
}`

type TestRunner struct {
}

// Run implements action.Runner.Run
func (tr *TestRunner) Run(context context.Context, action action.Action, uri string, options interface{}) (code int, data interface{}, err error) {
	log.Debugf("Ran Action: %v", uri)
	return 0, nil, nil
}

//TODO fix this test
func TestInit(t *testing.T) {
	// New  factory
	//f := &TimerFactory{}
	//tgr := f.New("flogo-timer")

	//runner := &TestRunner{}

	config := trigger.Config{}
	json.Unmarshal([]byte(testConfig), &config)
	//tgr.Init(config, runner)
}

/*
//TODO fix this test
func TestTimer(t *testing.T) {

	// New  factory
	f := &TimerFactory{}
	tgr := f.New("flogo-timer")

	tgr.Start()
	time.Sleep(time.Second * 2)
	defer tgr.Stop()

	log.Debug("Test timer done")
}
*/