contacts.go

package service

import "database/sql"

// Contact describes a contact in our database.
type Contact struct {
	Id    int    `json:"id"`
	Email string `json:"email"`
	Name  string `json:"name"`
}

// ===== ADD CONTACT ===================================================================================================

// AddContact inserts a new contact into the database.
func (db *Database) AddContact(c Contact) (int, error) {
	var contactId int
	err := db.Write(func(tx *Transaction) {
		contactId = tx.AddContact(c)
	})

	return contactId, err
}

// AddContact inserts a new contact within the transaction.
func (tx *Transaction) AddContact(c Contact) int {
	row := tx.QueryRow(
		"INSERT INTO contacts (email, name) VALUES ($1, $2) RETURNING id",
		c.Email,
		c.Name,
	)

	var id int
	if err := row.Scan(&id); err != nil {
		panic(err)
	}

	return id
}

// ===== GET CONTACT ===================================================================================================

// GetContactByEmail reads a Contact from the Database.
func (db *Database) GetContactByEmail(email string) (*Contact, error) {
	var contact *Contact
	err := db.Read(func(tx *Transaction) {
		contact = tx.GetContactByEmail(email)
	})

	return contact, err
}

// GetContactByEmail finds a contact given an email address. `nil` is returned if the Contact doesn't exist in the DB.
func (tx *Transaction) GetContactByEmail(email string) *Contact {
	row := tx.QueryRow(
		"SELECT id, email, name FROM contacts WHERE email = $1",
		email,
	)

	var contact Contact
	err := row.Scan(&contact.Id, &contact.Email, &contact.Name)
	if err == nil {
		return &contact
	} else if err == sql.ErrNoRows {
		return nil
	} else {
		panic(err)
	}
}