// Copyright 2020 The Gogs Authors. All rights reserved.
// Use of this source code is governed by a MIT-style
// license that can be found in the LICENSE file.

package db

import (
	"fmt"
	"testing"

	"github.com/stretchr/testify/assert"

	"gogs.io/gogs/internal/conf"
)

func Test_parsePostgreSQLHostPort(t *testing.T) {
	tests := []struct {
		info    string
		expHost string
		expPort string
	}{
		{info: "127.0.0.1:1234", expHost: "127.0.0.1", expPort: "1234"},
		{info: "127.0.0.1", expHost: "127.0.0.1", expPort: "5432"},
		{info: "[::1]:1234", expHost: "[::1]", expPort: "1234"},
		{info: "[::1]", expHost: "[::1]", expPort: "5432"},
		{info: "/tmp/pg.sock:1234", expHost: "/tmp/pg.sock", expPort: "1234"},
		{info: "/tmp/pg.sock", expHost: "/tmp/pg.sock", expPort: "5432"},
	}
	for _, test := range tests {
		t.Run("", func(t *testing.T) {
			host, port := parsePostgreSQLHostPort(test.info)
			assert.Equal(t, test.expHost, host)
			assert.Equal(t, test.expPort, port)
		})
	}
}

func Test_parseMSSQLHostPort(t *testing.T) {
	tests := []struct {
		info    string
		expHost string
		expPort string
	}{
		{info: "127.0.0.1:1234", expHost: "127.0.0.1", expPort: "1234"},
		{info: "127.0.0.1,1234", expHost: "127.0.0.1", expPort: "1234"},
		{info: "127.0.0.1", expHost: "127.0.0.1", expPort: "1433"},
	}
	for _, test := range tests {
		t.Run("", func(t *testing.T) {
			host, port := parseMSSQLHostPort(test.info)
			assert.Equal(t, test.expHost, host)
			assert.Equal(t, test.expPort, port)
		})
	}
}

func Test_parseDSN(t *testing.T) {
	t.Run("bad dialect", func(t *testing.T) {
		_, err := parseDSN(conf.DatabaseOpts{
			Type: "bad_dialect",
		})
		assert.Equal(t, "unrecognized dialect: bad_dialect", fmt.Sprintf("%v", err))
	})

	tests := []struct {
		name   string
		opts   conf.DatabaseOpts
		expDSN string
	}{
		{
			name: "mysql: unix",
			opts: conf.DatabaseOpts{
				Type:     "mysql",
				Host:     "/tmp/mysql.sock",
				Name:     "gogs",
				User:     "gogs",
				Password: "pa$$word",
			},
			expDSN: "gogs:pa$$word@unix(/tmp/mysql.sock)/gogs?charset=utf8mb4&parseTime=true",
		},
		{
			name: "mysql: tcp",
			opts: conf.DatabaseOpts{
				Type:     "mysql",
				Host:     "localhost:3306",
				Name:     "gogs",
				User:     "gogs",
				Password: "pa$$word",
			},
			expDSN: "gogs:pa$$word@tcp(localhost:3306)/gogs?charset=utf8mb4&parseTime=true",
		},

		{
			name: "postgres: unix",
			opts: conf.DatabaseOpts{
				Type:     "postgres",
				Host:     "/tmp/pg.sock",
				Name:     "gogs",
				User:     "gogs@local",
				Password: "pa$$word",
				SSLMode:  "disable",
			},
			expDSN: "postgres://gogs%40local:pa%24%24word@:5432/gogs?sslmode=disable&host=/tmp/pg.sock",
		},
		{
			name: "postgres: tcp",
			opts: conf.DatabaseOpts{
				Type:     "postgres",
				Host:     "127.0.0.1",
				Name:     "gogs",
				User:     "gogs@local",
				Password: "pa$$word",
				SSLMode:  "disable",
			},
			expDSN: "postgres://gogs%40local:pa%24%24word@127.0.0.1:5432/gogs?sslmode=disable",
		},

		{
			name: "mssql",
			opts: conf.DatabaseOpts{
				Type:     "mssql",
				Host:     "127.0.0.1",
				Name:     "gogs",
				User:     "gogs@local",
				Password: "pa$$word",
			},
			expDSN: "server=127.0.0.1; port=1433; database=gogs; user id=gogs@local; password=pa$$word;",
		},

		{
			name: "sqlite3",
			opts: conf.DatabaseOpts{
				Type: "sqlite3",
				Path: "/tmp/gogs.db",
			},
			expDSN: "file:/tmp/gogs.db?cache=shared&mode=rwc",
		},
	}
	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			dsn, err := parseDSN(test.opts)
			if err != nil {
				t.Fatal(err)
			}
			assert.Equal(t, test.expDSN, dsn)
		})
	}
}