Method InsertOrganizationMemberUser

admin/database/postgres/postgres.go:2095–2132

(ctx context.Context, orgID, userID, roleID string, attributes map[string]interface{}, ifNotExists bool)

}

func (c *connection) InsertOrganizationMemberUser(ctx context.Context, orgID, userID, roleID string, attributes map[string]interface{}, ifNotExists bool) (bool, error) {
	attrs, err := c.validateAttributes(attributes)
	if err != nil {
		return false, err
	}

	if !ifNotExists {
		res, err := c.getDB(ctx).ExecContext(ctx, "INSERT INTO users_orgs_roles (user_id, org_id, org_role_id, attributes) VALUES ($1, $2, $3, $4)", userID, orgID, roleID, attrs)
		if err != nil {
			return false, parseErr("org member", err)
		}
		rows, err := res.RowsAffected()
		if err != nil {
			return false, err
		}
		if rows == 0 {
			return false, fmt.Errorf("no rows affected when adding user to organization")
		}
		return true, nil
	}

	res, err := c.getDB(ctx).ExecContext(ctx, `
		INSERT INTO users_orgs_roles (user_id, org_id, org_role_id, attributes)
		VALUES ($1, $2, $3, $4)
		ON CONFLICT (user_id, org_id) DO NOTHING
	`, userID, orgID, roleID, attributes)
	if err != nil {
		return false, parseErr("org member", err)
	}
	rows, err := res.RowsAffected()
	if err != nil {
		return false, err
	}
	if rows > 1 {
		panic(fmt.Errorf("expected to update 0 or 1 row, but updated %d", rows))
	}
	return rows != 0, nil
}

func (c *connection) DeleteOrganizationMemberUser(ctx context.Context, orgID, userID string) error {
	res, err := c.getDB(ctx).ExecContext(ctx, "DELETE FROM users_orgs_roles WHERE user_id = $1 AND org_id = $2", userID, orgID)