release: v1.1.4, merge pr7 and pr8

Place at first line of the function body a function type safe guard
check.

README.md

@@ -6,7 +6,7 @@
 <div align="center" style="text-align: center;">
 
 ![Go version](https://img.shields.io/badge/go-%3E%3D1.16<recommend>-9cf)
-[![Release](https://img.shields.io/badge/release-1.1.0-green.svg)](https://github.com/duke-git/lancet/releases)
+[![Release](https://img.shields.io/badge/release-1.1.4-green.svg)](https://github.com/duke-git/lancet/releases)
 [![GoDoc](https://godoc.org/github.com//duke-git/lancet?status.svg)](https://pkg.go.dev/github.com/duke-git/lancet)
 [![Go Report Card](https://goreportcard.com/badge/github.com/duke-git/lancet)](https://goreportcard.com/report/github.com/duke-git/lancet)
 [![codecov](https://codecov.io/gh/duke-git/lancet/branch/main/graph/badge.svg?token=FC48T1F078)](https://codecov.io/gh/duke-git/lancet)

README_zh-CN.md

@@ -6,7 +6,7 @@
 <div align="center" style="text-align: center;">
 
 ![Go version](https://img.shields.io/badge/go-%3E%3D1.16<recommend>-9cf)
-[![Release](https://img.shields.io/badge/release-1.1.0-green.svg)](https://github.com/duke-git/lancet/releases)
+[![Release](https://img.shields.io/badge/release-1.1.4-green.svg)](https://github.com/duke-git/lancet/releases)
 [![GoDoc](https://godoc.org/github.com//duke-git/lancet?status.svg)](https://pkg.go.dev/github.com/duke-git/lancet)
 [![Go Report Card](https://goreportcard.com/badge/github.com/duke-git/lancet)](https://goreportcard.com/report/github.com/duke-git/lancet)
 [![codecov](https://codecov.io/gh/duke-git/lancet/branch/main/graph/badge.svg?token=FC48T1F078)](https://codecov.io/gh/duke-git/lancet)

datetime/datetime.go

@@ -25,7 +25,7 @@
 package datetime
 
 import (
-	"strconv"
+	"fmt"
 	"time"
 )
 
@@ -56,24 +56,17 @@ func init() {
 
 // AddMinute add or sub minute to the time
 func AddMinute(t time.Time, minute int64) time.Time {
-	s := strconv.FormatInt(minute, 10)
-	m, _ := time.ParseDuration(s + "m")
-	return t.Add(m)
+	return t.Add(time.Minute * time.Duration(minute))
 }
 
 // AddHour add or sub hour to the time
 func AddHour(t time.Time, hour int64) time.Time {
-	s := strconv.FormatInt(hour, 10)
-	h, _ := time.ParseDuration(s + "h")
-	return t.Add(h)
+	return t.Add(time.Hour * time.Duration(hour))
 }
 
 // AddDay add or sub day to the time
 func AddDay(t time.Time, day int64) time.Time {
-	dayHours := day * 24
-	d := strconv.FormatInt(dayHours, 10)
-	h, _ := time.ParseDuration(d + "h")
-	return t.Add(h)
+	return t.Add(24 * time.Hour * time.Duration(day))
 }
 
 // GetNowDate return format yyyy-mm-dd of current date
@@ -109,7 +102,11 @@ func FormatTimeToStr(t time.Time, format string) string {
 }
 
 // FormatStrToTime convert string to time
-func FormatStrToTime(str, format string) time.Time {
-	t, _ := time.Parse(timeFormat[format], str)
-	return t
+func FormatStrToTime(str, format string) (time.Time, error) {
+	v, ok := timeFormat[format]
+	if !ok {
+		return time.Time{}, fmt.Errorf("format %s not found", format)
+	}
+
+	return time.Parse(v, str)
 }

datetime/datetime_test.go

@@ -135,7 +135,10 @@ func TestFormatStrToTime(t *testing.T) {
 		"2021/01"}
 
 	for i := 0; i < len(cases); i++ {
-		res := FormatStrToTime(datetimeStr[i], cases[i])
+		res, err := FormatStrToTime(datetimeStr[i], cases[i])
+		if err != nil {
+			t.Fatal(err)
+		}
 		expected, _ := time.Parse(formats[i], datetimeStr[i])
 		if res != expected {
 			utils.LogFailedTestInfo(t, "FormatTimeToStr", cases[i], expected, res)

function/function.go

@@ -11,10 +11,12 @@ import (
 
 // After creates a function that invokes func once it's called n or more times
 func After(n int, fn interface{}) func(args ...interface{}) []reflect.Value {
+	// Catch programming error while constructing the closure
+	MustBeFunction(fn)
 	return func(args ...interface{}) []reflect.Value {
 		n--
 		if n < 1 {
-			return invokeFunc(fn, args...)
+			return unsafeInvokeFunc(fn, args...)
 		}
 		return nil
 	}
@@ -22,11 +24,12 @@ func After(n int, fn interface{}) func(args ...interface{}) []reflect.Value {
 
 // Before creates a function that invokes func once it's called less than n times
 func Before(n int, fn interface{}) func(args ...interface{}) []reflect.Value {
+	// Catch programming error while constructing the closure
+	MustBeFunction(fn)
 	var res []reflect.Value
-
 	return func(args ...interface{}) []reflect.Value {
 		if n > 0 {
-			res = invokeFunc(fn, args...)
+			res = unsafeInvokeFunc(fn, args...)
 		}
 		if n <= 0 {
 			fn = nil
@@ -35,6 +38,7 @@ func Before(n int, fn interface{}) func(args ...interface{}) []reflect.Value {
 		return res
 	}
 }
+
 // Fn is for curry function which is func(...interface{}) interface{}
 type Fn func(...interface{}) interface{}
 
@@ -68,11 +72,12 @@ func Delay(delay time.Duration, fn interface{}, args ...interface{}) {
 
 // Schedule invoke function every duration time, util close the returned bool chan
 func Schedule(d time.Duration, fn interface{}, args ...interface{}) chan bool {
+	// Catch programming error while constructing the closure
+	MustBeFunction(fn)
 	quit := make(chan bool)
-
 	go func() {
 		for {
-			invokeFunc(fn, args...)
+			unsafeInvokeFunc(fn, args...)
 			select {
 			case <-time.After(d):
 			case <-quit:

function/function_util.go

@@ -14,6 +14,15 @@ func invokeFunc(fn interface{}, args ...interface{}) []reflect.Value {
 	return fv.Call(params)
 }
 
+func unsafeInvokeFunc(fn interface{}, args ...interface{}) []reflect.Value {
+	fv := reflect.ValueOf(fn)
+	params := make([]reflect.Value, len(args))
+	for i, item := range args {
+		params[i] = reflect.ValueOf(item)
+	}
+	return fv.Call(params)
+}
+
 func functionValue(function interface{}) reflect.Value {
 	v := reflect.ValueOf(function)
 	if v.Kind() != reflect.Func {
@@ -21,3 +30,10 @@ func functionValue(function interface{}) reflect.Value {
 	}
 	return v
 }
+
+func MustBeFunction(function interface{}) {
+	v := reflect.ValueOf(function)
+	if v.Kind() != reflect.Func {
+		panic(fmt.Sprintf("Invalid function type, value of type %T", function))
+	}
+}

netutil/request_test.go

@@ -11,16 +11,12 @@ import (
 )
 
 func TestHttpGet(t *testing.T) {
-	_, e := HttpGet("", nil)
-	if e == nil {
-		t.FailNow()
+	url := "https://jsonplaceholder.typicode.com/todos/1"
+	header := map[string]string{
+		"Content-Type": "application/json",
 	}
 
-	url := "https://gutendex.com/books?"
-	queryParams := make(map[string]interface{})
-	queryParams["ids"] = "1"
-
-	resp, err := HttpGet(url, nil, queryParams)
+	resp, err := HttpGet(url, header)
 	if err != nil {
 		log.Fatal(err)
 		t.FailNow()
@@ -28,23 +24,20 @@ func TestHttpGet(t *testing.T) {
 
 	body, _ := ioutil.ReadAll(resp.Body)
 	fmt.Println("response: ", resp.StatusCode, string(body))
-
 }
 
 func TestHttpPost(t *testing.T) {
-	url := "http://public-api-v1.aspirantzhang.com/users"
-	type User struct {
-		Name  string `json:"name"`
-		Email string `json:"email"`
-	}
-	user := User{
-		"test",
-		"test@test.com",
-	}
-	bodyParams, _ := json.Marshal(user)
+	url := "https://jsonplaceholder.typicode.com/todos"
 	header := map[string]string{
 		"Content-Type": "application/json",
 	}
+	type Todo struct {
+		UserId int    `json:"userId"`
+		Title  string `json:"title"`
+	}
+	todo := Todo{1, "TestAddToDo"}
+	bodyParams, _ := json.Marshal(todo)
+
 	resp, err := HttpPost(url, header, nil, bodyParams)
 	if err != nil {
 		log.Fatal(err)
@@ -55,19 +48,18 @@ func TestHttpPost(t *testing.T) {
 }
 
 func TestHttpPut(t *testing.T) {
-	url := "http://public-api-v1.aspirantzhang.com/users/10420"
-	type User struct {
-		Name  string `json:"name"`
-		Email string `json:"email"`
-	}
-	user := User{
-		"test",
-		"test@test.com",
-	}
-	bodyParams, _ := json.Marshal(user)
+	url := "https://jsonplaceholder.typicode.com/todos/1"
 	header := map[string]string{
 		"Content-Type": "application/json",
 	}
+	type Todo struct {
+		Id     int    `json:"id"`
+		UserId int    `json:"userId"`
+		Title  string `json:"title"`
+	}
+	todo := Todo{1, 1, "TestPutToDo"}
+	bodyParams, _ := json.Marshal(todo)
+
 	resp, err := HttpPut(url, header, nil, bodyParams)
 	if err != nil {
 		log.Fatal(err)
@@ -77,8 +69,30 @@ func TestHttpPut(t *testing.T) {
 	fmt.Println("response: ", resp.StatusCode, string(body))
 }
 
+func TestHttpPatch(t *testing.T) {
+	url := "https://jsonplaceholder.typicode.com/todos/1"
+	header := map[string]string{
+		"Content-Type": "application/json",
+	}
+	type Todo struct {
+		Id     int    `json:"id"`
+		UserId int    `json:"userId"`
+		Title  string `json:"title"`
+	}
+	todo := Todo{1, 1, "TestPatchToDo"}
+	bodyParams, _ := json.Marshal(todo)
+
+	resp, err := HttpPatch(url, header, nil, bodyParams)
+	if err != nil {
+		log.Fatal(err)
+		t.FailNow()
+	}
+	body, _ := ioutil.ReadAll(resp.Body)
+	fmt.Println("response: ", resp.StatusCode, string(body))
+}
+
 func TestHttpDelete(t *testing.T) {
-	url := "http://public-api-v1.aspirantzhang.com/users/10420"
+	url := "https://jsonplaceholder.typicode.com/todos/1"
 	resp, err := HttpDelete(url)
 	if err != nil {
 		log.Fatal(err)
@@ -104,25 +118,29 @@ func TestConvertMapToQueryString(t *testing.T) {
 }
 
 func TestParseResponse(t *testing.T) {
-	url := "http://public-api-v1.aspirantzhang.com/users"
-	type User struct {
-		Id    int    `json:"id"`
-		Name  string `json:"name"`
-		Email string `json:"email"`
+	url := "https://jsonplaceholder.typicode.com/todos/1"
+	header := map[string]string{
+		"Content-Type": "application/json",
 	}
-	type UserResp struct {
-		Data []User `json:"data"`
-	}
-	resp, err := HttpGet(url)
+
+	resp, err := HttpGet(url, header)
 	if err != nil {
 		log.Fatal(err)
 		t.FailNow()
 	}
-	userResp := &UserResp{}
-	err = ParseHttpResponse(resp, userResp)
+
+	type Todo struct {
+		Id        int    `json:"id"`
+		UserId    int    `json:"userId"`
+		Title     string `json:"title"`
+		Completed bool   `json:"completed"`
+	}
+
+	toDoResp := &Todo{}
+	err = ParseHttpResponse(resp, toDoResp)
 	if err != nil {
 		log.Fatal(err)
 		t.FailNow()
 	}
-	fmt.Println(userResp.Data)
+	fmt.Println("response: ", toDoResp)
 }

slice/slice.go

@@ -100,15 +100,15 @@ func Every(slice, function interface{}) bool {
 		panic("function param should be of type func(int, " + elemType.String() + ")" + reflect.ValueOf(true).Type().String())
 	}
 
-	var indexes []int
+	var currentLength int
 	for i := 0; i < sv.Len(); i++ {
 		flag := fn.Call([]reflect.Value{reflect.ValueOf(i), sv.Index(i)})[0]
 		if flag.Bool() {
-			indexes = append(indexes, i)
+			currentLength++
 		}
 	}
 
-	return len(indexes) == sv.Len()
+	return currentLength == sv.Len()
 }
 
 // Some return true if any of the values in the list pass the predicate function.
@@ -474,7 +474,7 @@ func Intersection(slices ...interface{}) interface{} {
 	}
 
 	res := Reduce(slices, reduceFunc, nil)
-	return Union(res)
+	return Unique(res)
 }
 
 // ReverseSlice return slice of element order is reversed to the given slice

strutil/string.go

@@ -8,6 +8,7 @@ import (
 	"regexp"
 	"strings"
 	"unicode"
+	"unicode/utf8"
 )
 
 // CamelCase covert string to camelCase string.
@@ -59,20 +60,10 @@ func LowerFirst(s string) string {
 		return ""
 	}
 
-	res := ""
-	for i, v := range []rune(s) {
-		if i == 0 {
-			if v >= 65 && v <= 96 {
-				v += 32
-				res += string(v)
-			} else {
-				return s
-			}
-		} else {
-			res += string(v)
-		}
-	}
-	return res
+	r, size := utf8.DecodeRuneInString(s)
+	r = unicode.ToLower(r)
+
+	return string(r) + s[size:]
 }
 
 // PadEnd pads string on the right side if it's shorter than size.

strutil/string_test.go

@@ -70,6 +70,7 @@ func TestLowerFirst(t *testing.T) {
 	lowerFirst(t, "foo", "foo")
 	lowerFirst(t, "BAR", "bAR")
 	lowerFirst(t, "FOo", "fOo")
+	lowerFirst(t, "FOo大", "fOo大")
 }
 
 func lowerFirst(t *testing.T, test string, expected string) {