feat: add new version for common code

Author: grokify

carrier.go

@@ -0,0 +1,10 @@
+package gophonenumbers
+
+type CarrierNumberInfo struct {
+	E164Number        string `json:"e164Number"`
+	MobileCountryCode string `json:"mobileCountryCode,omitempty"`
+	MobileNetworkCode string `json:"mobileNetworkCode,omitempty"`
+	Name              string `json:"name,omitempty"`
+	LineType          string `json:"lineType,omitempty"`
+	ErrorCode         string `json:"errorCode,omitempty"`
+}

components.go

@@ -0,0 +1,51 @@
+package gophonenumbers
+
+import (
+	"fmt"
+	"regexp"
+	"strconv"
+	"strings"
+)
+
+var rxNANPFormat = regexp.MustCompile(`^\+(1([0-9]{3})([0-9]{3})([0-9]{4}))$`)
+
+type Components struct {
+	E164Number       string
+	E164NumberUint   uint
+	RegionCode       string
+	CountryCode      uint
+	NANPAreaCode     uint // NPA - Numbering plan area code
+	NANPExchangeCode uint // NXX - Central office (exchange) code
+	NANPLineNumber   uint // xxxx - Line number or subscriber number
+}
+
+func (num *Number) NANPComponents() (Components, error) {
+	num.E164Number = strings.TrimSpace(num.E164Number)
+	comp := Components{E164Number: num.E164Number}
+	m := rxNANPFormat.FindAllStringSubmatch(num.E164Number, -1)
+	if len(m) == 0 {
+		return comp, fmt.Errorf("number is not E.164 [%s]", num.E164Number)
+	}
+	comp.CountryCode = 1
+	e164int, err := strconv.Atoi(m[0][1])
+	if err != nil {
+		panic(fmt.Sprintf("ParseE164 [%v]", err.Error()))
+	}
+	comp.E164NumberUint = uint(e164int)
+	areaCode, err := strconv.Atoi(m[0][2])
+	if err != nil {
+		panic(fmt.Sprintf("ParseE164 [%v]", err.Error()))
+	}
+	comp.NANPAreaCode = uint(areaCode)
+	exchangeCode, err := strconv.Atoi(m[0][3])
+	if err != nil {
+		panic(fmt.Sprintf("ParseE164 [%v]", err.Error()))
+	}
+	comp.NANPExchangeCode = uint(exchangeCode)
+	lineNumber, err := strconv.Atoi(m[0][4])
+	if err != nil {
+		panic(fmt.Sprintf("ParseE164 [%v]", err.Error()))
+	}
+	comp.NANPLineNumber = uint(lineNumber)
+	return comp, nil
+}

components_test.go

@@ -0,0 +1,48 @@
+package gophonenumbers
+
+import (
+	"testing"
+)
+
+var parseE164Tests = []struct {
+	e164Number   string
+	e164Uint     uint
+	countryCode  uint
+	areaCode     uint
+	exchangeCode uint
+	lineNumber   uint
+}{
+	{"+16505550100", uint(16505550100), uint(1), uint(650), uint(555), uint(100)},
+	{"+14155550199", uint(14155550199), uint(1), uint(415), uint(555), uint(199)},
+}
+
+func TestParseE164(t *testing.T) {
+	for _, tt := range parseE164Tests {
+		num := Number{E164Number: tt.e164Number}
+		got, err := num.NANPComponents()
+		if err != nil {
+			t.Errorf("Number.NANPComponents(\"%s\") Want: [%v] Got: [%v]",
+				tt.e164Number, tt.e164Uint, got.E164NumberUint)
+		}
+		if got.E164NumberUint != tt.e164Uint {
+			t.Errorf("Number.NANPComponents() Want: [%v] Got: [%v]",
+				tt.e164Uint, got.E164NumberUint)
+		}
+		if got.CountryCode != tt.countryCode {
+			t.Errorf("Number.NANPComponents() Want: [%v] Got: [%v]",
+				tt.countryCode, got.CountryCode)
+		}
+		if got.NANPAreaCode != tt.areaCode {
+			t.Errorf("Number.NANPComponents(\"%s\") Want: [%v] Got: [%v]",
+				tt.e164Number, tt.areaCode, got.NANPAreaCode)
+		}
+		if got.NANPExchangeCode != tt.exchangeCode {
+			t.Errorf("Number.NANPComponents(\"%s\") Want: [%v] Got: [%v]",
+				tt.e164Number, tt.exchangeCode, got.NANPExchangeCode)
+		}
+		if got.NANPLineNumber != tt.lineNumber {
+			t.Errorf("Number.NANPComponents(\"%s\") Want: [%v] Got: [%v]",
+				tt.e164Number, tt.lineNumber, got.NANPLineNumber)
+		}
+	}
+}

constants.go

@@ -0,0 +1,17 @@
+package gophonenumbers
+
+const (
+	CarrierATT     = "att"
+	CarrierSprint  = "sprint"
+	CarrierTMobile = "tmobile"
+	CarrierVerizon = "verizon"
+
+	LineTypeLocal    = "local"
+	LineTypeMobile   = "mobile"
+	LineTypeTollFree = "tollfree"
+
+	SourceEkata     = "ekata"
+	SourceNumverify = "numverify"
+	SourcePlivo     = "plivo"
+	SourceTwilio    = "twilio"
+)

lookup.go

@@ -0,0 +1,65 @@
+package gophonenumbers
+
+import (
+	"errors"
+	"fmt"
+	"sort"
+	"time"
+)
+
+type Lookup struct {
+	CarrierNumberInfo CarrierNumberInfo      `json:"carrierNumberInfo"`
+	LookupSource      string                 `json:"lookupSource"`
+	LookupTime        time.Time              `json:"lookupTime"`
+	LookupResponse    map[string]interface{} `json:"lookupResponse"`
+}
+
+type LookupSet struct {
+	LookupMap map[string]Lookup `json:"lookupMap"`
+}
+
+func NewLookupSet() LookupSet {
+	return LookupSet{
+		LookupMap: map[string]Lookup{}}
+}
+
+func (set LookupSet) Add(lookup Lookup) {
+	if set.LookupMap == nil {
+		set.LookupMap = map[string]Lookup{}
+	}
+	set.LookupMap[lookup.LookupTime.Format(time.RFC3339)] = lookup
+}
+
+func (set LookupSet) Latest(source string) (Lookup, error) {
+	if set.LookupMap == nil || len(set.LookupMap) == 0 {
+		return Lookup{}, errors.New("no latest lookup. lookupSet is empty.")
+	}
+	times := []string{}
+	for dtKey, lookup := range set.LookupMap {
+		if len(source) > 0 && lookup.LookupSource != source {
+			continue
+		}
+		times = append(times, dtKey)
+	}
+	if len(times) == 0 {
+		return Lookup{}, fmt.Errorf("no lookup for source [%s]", string(source))
+	}
+	if len(times) == 1 {
+		return set.LookupMap[times[0]], nil
+	}
+	sort.Strings(times)
+	return set.LookupMap[times[len(times)-1]], nil
+}
+
+func (set LookupSet) Validate() {
+	if set.LookupMap == nil || len(set.LookupMap) == 0 {
+		return
+	}
+	for dtKey, lookup := range set.LookupMap {
+		_, err := time.Parse(time.RFC3339, dtKey)
+		if err != nil {
+			delete(set.LookupMap, dtKey)
+			set.LookupMap[lookup.LookupTime.Format(time.RFC3339)] = lookup
+		}
+	}
+}

number.go

@@ -0,0 +1,34 @@
+package gophonenumbers
+
+import (
+	"fmt"
+	"strings"
+)
+
+type Number struct {
+	E164Number        string            `json:"e164Number"`
+	CountryCode       string            `json:"countryCode"`
+	CarrierNumberInfo CarrierNumberInfo `json:"carrier"`
+	Lookups           LookupSet         `json:"lookups"`
+}
+
+func NewNumber() Number {
+	return Number{
+		Lookups: NewLookupSet()}
+}
+
+func (num *Number) SetLatest(source string) error {
+	latest, err := num.Lookups.Latest(source)
+	if err != nil {
+		return err
+	}
+	latest.CarrierNumberInfo.E164Number = strings.TrimSpace(latest.CarrierNumberInfo.E164Number)
+	num.E164Number = strings.TrimSpace(num.E164Number)
+	if num.E164Number != latest.CarrierNumberInfo.E164Number {
+		return fmt.Errorf("lookup number mismatch: number [%s] lookup [%s]",
+			num.E164Number,
+			latest.CarrierNumberInfo.E164Number)
+	}
+	num.CarrierNumberInfo = latest.CarrierNumberInfo
+	return nil
+}

number_set.go

@@ -0,0 +1,46 @@
+package gophonenumbers
+
+import (
+	"errors"
+	"io/fs"
+
+	"github.com/grokify/simplego/encoding/jsonutil"
+)
+
+type NumberSet struct {
+	Numbers map[string]Number `json:"numbers"`
+}
+
+func NewNumberSet() NumberSet {
+	return NumberSet{Numbers: map[string]Number{}}
+}
+
+func (set *NumberSet) Add(num Number) error {
+	if len(num.E164Number) == 0 {
+		return errors.New("no E.164 number")
+	}
+	set.Numbers[num.E164Number] = num
+	return nil
+}
+
+func (set *NumberSet) MapNumberCarrierName() map[string]string {
+	mss := map[string]string{}
+	for _, num := range set.Numbers {
+		mss[num.E164Number] = num.CarrierNumberInfo.Name
+	}
+	return mss
+}
+
+func (set *NumberSet) MapNumberLineType() map[string]string {
+	mss := map[string]string{}
+	for _, num := range set.Numbers {
+		mss[num.E164Number] = num.CarrierNumberInfo.LineType
+	}
+	return mss
+}
+
+func (set *NumberSet) WriteFileJSON(filename, prefix, indent string, perm fs.FileMode) error {
+	return jsonutil.WriteFile(filename, set, prefix, indent, perm)
+}
+
+type MapStringString map[string]string