package egoscale

import (
	"context"
	"fmt"
	"testing"
)

func TestRunstatusIncidentGenericError(t *testing.T) { // nolint: dupl
	ts := newTestServer()
	defer ts.Close()

	cs := newTestClient(ts.URL)

	p := response{200, jsonContentType, fmt.Sprintf(`{"subdomain": "testpage", "incidents_url": %q}`, ts.URL)}
	r200 := response{200, jsonContentType, `ERROR`}
	r400 := response{400, jsonContentType, `{"detail": "error"}`}

	ts.addResponse(r200, r400)
	_, err := cs.ListRunstatusIncidents(context.TODO(), RunstatusPage{IncidentsURL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 200 bad json: got nil")
	}

	_, err = cs.ListRunstatusIncidents(context.TODO(), RunstatusPage{IncidentsURL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 400: got nil")
	}

	ts.addResponse(r200, r400)
	_, err = cs.GetRunstatusIncident(context.TODO(), RunstatusIncident{URL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 200 bad json: got nil")
	}

	_, err = cs.GetRunstatusIncident(context.TODO(), RunstatusIncident{URL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 400: got nil")
	}

	ts.addResponse(r200, p, r200, r400, p, r400)
	_, err = cs.CreateRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 200 bad json: got nil")
	}

	_, err = cs.CreateRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 200 bad json: got nil")
	}

	_, err = cs.CreateRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 400: got nil")
	}

	_, err = cs.CreateRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL})
	if err == nil {
		t.Errorf("error expected on 400: got nil")
	}
}

func TestRunstatusListIncidents(t *testing.T) {
	ts := newTestServer()
	defer ts.Close()

	cs := newTestClient(ts.URL)

	is := response{200, jsonContentType, `
{
  "next": null,
  "previous": null,
  "results": [
    {
      "id": 90,
      "url": "https://example.org/pages/testpage/incidents/90",
      "services": [
        "API"
      ],
      "start_date": "2018-11-14T15:37:29Z",
      "end_date": "2018-11-14T15:38:19Z",
      "status": "resolved",
      "events": [
        {
          "created": "2018-11-14T15:38:19Z",
          "text": "fini",
          "status": "resolved",
          "state": "operational"
        },
        {
          "created": "2018-11-14T15:38:09Z",
          "text": "c'est la vie!",
          "status": "identified",
          "state": "degraded_performance"
        },
        {
          "created": "2018-11-14T15:37:29Z",
          "text": "Foo bar",
          "status": "monitoring",
          "state": "operational"
        }
      ],
      "status_text": "fini",
      "state": "degraded_performance",
      "title": "AAAH",
      "events_url": "https://example.org/pages/testpage/incidents/90/events",
      "post_mortem": "# foo bar\n\nc'est la life",
      "real_time": true
    }
  ]
}`}

	i := response{200, jsonContentType, `{
  "id": 90,
  "status": "degraded_performance"
}`}

	p := response{200, jsonContentType, fmt.Sprintf(`
{
  "url": "https://api.runstatus.com/pages/testpage",
  "incidents_url": %q,
  "incidents": [
    {
      "id": 90,
      "url": "https://example.org/pages/testpage/incidents/90",
      "services": [
        "API"
      ],
      "start_date": "2018-11-14T15:37:29Z",
      "end_date": "2018-11-14T15:38:19Z",
      "status": "resolved",
      "events": [
        {
          "created": "2018-11-14T15:38:19Z",
          "text": "fini",
          "status": "resolved",
          "state": "operational"
        },
        {
          "created": "2018-11-14T15:38:09Z",
          "text": "c'est la vie!",
          "status": "identified",
          "state": "degraded_performance"
        },
        {
          "created": "2018-11-14T15:37:29Z",
          "text": "Foo bar",
          "status": "monitoring",
          "state": "operational"
        }
      ],
      "status_text": "fini",
      "state": "degraded_performance",
      "title": "AAAH",
      "events_url": "https://example.org/pages/testpage/incidents/90/events",
      "post_mortem": "# foo bar\n\nc'est la life",
      "real_time": true
    }
  ],
  "subdomain": "testpage"
}`, ts.URL)}

	ts.addResponse(is)
	incidents, err := cs.ListRunstatusIncidents(context.TODO(), RunstatusPage{IncidentsURL: ts.URL})
	if err != nil {
		t.Fatal(err)
	}

	if len(incidents) != 1 {
		t.Errorf("1 incident expected: got %d", len(incidents))
	}

	if incidents[0].ID != 90 {
		t.Errorf("id 90 expected: got %d", incidents[0].ID)
	}

	ts.addResponse(i)
	incident, err := cs.GetRunstatusIncident(context.TODO(), RunstatusIncident{URL: ts.URL})
	if err != nil {
		t.Fatal(err)
	}

	if incident.ID != 90 {
		t.Errorf("bad incident, %#v", incident)
	}

	ts.addResponse(p)
	incident, err = cs.GetRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL, Title: "AAAH"})
	if err != nil {
		t.Fatal(err)
	}

	if incident.ID != 90 {
		t.Errorf("bad incident, %#v", incident)
	}

	ts.addResponse(p)
	incident, err = cs.GetRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL, ID: 90})
	if err != nil {
		t.Fatal(err)
	}

	if incident.Title != "AAAH" {
		t.Errorf("bad incident, %#v", incident)
	}
}

func TestRunstatusPaginateIncidents(t *testing.T) {
	ts := newTestServer()
	defer ts.Close()

	cs := newTestClient(ts.URL)

	is := response{200, jsonContentType, fmt.Sprintf(`
	{
		"count":64,
		"next": %q,
		"previous":null,
		"results": [
			{
				"id": 90,
				"url": "https://example.org/pages/testpage/incidents/90",
				"services": [
					"API"
				],
				"start_date": "2018-11-14T15:37:29Z",
				"end_date": "2018-11-14T15:38:19Z",
				"status": "resolved",
				"events": [
					{
						"created": "2018-11-14T15:38:19Z",
						"text": "fini",
						"status": "resolved",
						"state": "operational"
					},
					{
						"created": "2018-11-14T15:38:09Z",
						"text": "c'est la vie!",
						"status": "identified",
						"state": "degraded_performance"
					},
					{
						"created": "2018-11-14T15:37:29Z",
						"text": "Foo bar",
						"status": "monitoring",
						"state": "operational"
					}
				],
				"status_text": "fini",
				"state": "degraded_performance",
				"title": "AAAH",
				"events_url": "https://example.org/pages/testpage/incidents/90/events",
				"post_mortem": "# foo bar\n\nc'est la life",
				"real_time": true
			}
		]
	}`, ts.URL)}

	p := response{200, jsonContentType, `
	{
		"count":64,
		"next": null,
		"previous":null,
		"incidents": [
			{
				"id": 90,
				"url": "https://example.org/pages/testpage/incidents/90",
				"services": [
					"API"
				],
				"start_date": "2018-11-14T15:37:29Z",
				"end_date": "2018-11-14T15:38:19Z",
				"status": "resolved",
				"events": [
					{
						"created": "2018-11-14T15:38:19Z",
						"text": "fini",
						"status": "resolved",
						"state": "operational"
					},
					{
						"created": "2018-11-14T15:38:09Z",
						"text": "c'est la vie!",
						"status": "identified",
						"state": "degraded_performance"
					},
					{
						"created": "2018-11-14T15:37:29Z",
						"text": "Foo bar",
						"status": "monitoring",
						"state": "operational"
					}
				],
				"status_text": "fini",
				"state": "degraded_performance",
				"title": "AAAH",
				"events_url": "https://example.org/pages/testpage/incidents/90/events",
				"post_mortem": "# foo bar\n\nc'est la life",
				"real_time": true
			}
		]
	}`}

	ts.addResponse(is, p)
	cs.PaginateRunstatusIncidents(context.TODO(), RunstatusPage{IncidentsURL: ts.URL}, func(incident *RunstatusIncident, e error) bool {
		if e != nil {
			t.Errorf(`reply error not expected: %v`, e)
		}

		if incident.Title != "AAAH" {
			t.Errorf(`AAAH was expected but got %q`, incident.Title)
		}

		return false
	})
}

func TestRunstatusIncidentDelete(t *testing.T) {
	ts := newTestServer(response{204, jsonContentType, ""})
	defer ts.Close()

	cs := newTestClient(ts.URL)

	if err := cs.DeleteRunstatusIncident(context.TODO(), RunstatusIncident{}); err == nil {
		t.Error("incident without a status should fail")
	}

	if err := cs.DeleteRunstatusIncident(context.TODO(), RunstatusIncident{URL: ts.URL}); err != nil {
		t.Error(err)
	}
}

func TestRunstatusIncidentCreate(t *testing.T) {
	ts := newTestServer()
	defer ts.Close()
	ts.addResponse(
		response{200, jsonContentType, fmt.Sprintf(`{"incidents_url": %q, "subdomain": "d"}`, ts.URL)},
		response{201, jsonContentType, `{"url": "...", "name": "hello"}`},
	)

	cs := newTestClient(ts.URL)

	if _, err := cs.CreateRunstatusIncident(context.TODO(), RunstatusIncident{}); err == nil {
		t.Error("incident without a status should fail")
	}

	if _, err := cs.CreateRunstatusIncident(context.TODO(), RunstatusIncident{PageURL: ts.URL}); err != nil {
		t.Error(err)
	}
}