Method CreateIdentity

database/identity.go:38–61

CreateIdentity inserts a new identity record into the database. It generates a unique IdentityID, sets the creation timestamp, and stores the identity metadata. Parameters: - identity: The identity object to be inserted. Returns: - The created identity object, or an error if the creation fails.

(identity model.Identity)

// Returns:
// - The created identity object, or an error if the creation fails.
func (d Datasource) CreateIdentity(identity model.Identity) (model.Identity, error) {
	// Marshal metadata into JSON format
	metaDataJSON, err := json.Marshal(identity.MetaData)
	if err != nil {
		return identity, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to marshal metadata", err)
	}

	// Generate a unique identity ID and set the creation timestamp
	identity.IdentityID = model.GenerateUUIDWithSuffix("idt")
	identity.CreatedAt = time.Now()

	// Insert the identity record into the database
	_, err = d.Conn.ExecContext(context.Background(), `
		INSERT INTO ledgerforge.identity (identity_id, identity_type, first_name, last_name, other_names, gender, dob, email_address, phone_number, nationality, organization_name, category, street, country, state, post_code, city, created_at, meta_data)
		VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19)
	`, identity.IdentityID, identity.IdentityType, identity.FirstName, identity.LastName, identity.OtherNames, identity.Gender, identity.DOB, identity.EmailAddress, identity.PhoneNumber, identity.Nationality, identity.OrganizationName, identity.Category, identity.Street, identity.Country, identity.State, identity.PostCode, identity.City, identity.CreatedAt, metaDataJSON)
	// Handle any errors that occur during insertion
	if err != nil {
		return identity, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to create identity", err)
	}

	// Return the created identity
	return identity, nil
}

// GetIdentityByID retrieves an identity from the database based on the given identity ID.
// It starts a transaction, executes a query to fetch the identity details, and commits the transaction upon success.