compiles, basic issues fixed

Server type is found under the Jellyfin settings tab, where you can
change it to emby. Currently:

* logs in
* creates users
* parses accounts

mediabrowser/emby.go

@@ -3,181 +3,13 @@ package mediabrowser
 // Almost identical to jfapi, with the most notable change being the password workaround.
 
 import (
-	"bytes"
-	"compress/gzip"
 	"encoding/json"
 	"fmt"
-	"io"
-	"io/ioutil"
 	"net/http"
-	"strings"
 	"time"
-
-	"github.com/hrfee/jfa-go/common"
 )
 
-// NewEmby returns a new Emby object.
-func NewEmby(server, client, version, device, deviceID string, timeoutHandler common.TimeoutHandler, cacheTimeout int) (*MediaBrowserStruct, error) {
-	emby := &Emby{}
-	emby.Server = server
-	emby.client = client
-	emby.version = version
-	emby.device = device
-	emby.deviceID = deviceID
-	emby.useragent = fmt.Sprintf("%s/%s", client, version)
-	emby.timeoutHandler = timeoutHandler
-	emby.auth = fmt.Sprintf("MediaBrowser Client=\"%s\", Device=\"%s\", DeviceId=\"%s\", Version=\"%s\"", client, device, deviceID, version)
-	emby.header = map[string]string{
-		"Accept":               "application/json",
-		"Content-type":         "application/json; charset=UTF-8",
-		"X-Application":        emby.useragent,
-		"Accept-Charset":       "UTF-8,*",
-		"Accept-Encoding":      "gzip",
-		"User-Agent":           emby.useragent,
-		"X-Emby-Authorization": emby.auth,
-	}
-	emby.httpClient = &http.Client{
-		Timeout: 10 * time.Second,
-	}
-	infoURL := fmt.Sprintf("%s/System/Info/Public", server)
-	req, _ := http.NewRequest("GET", infoURL, nil)
-	resp, err := emby.httpClient.Do(req)
-	defer emby.timeoutHandler()
-	if err == nil {
-		data, _ := ioutil.ReadAll(resp.Body)
-		json.Unmarshal(data, &emby.ServerInfo)
-	}
-	emby.cacheLength = cacheTimeout
-	emby.CacheExpiry = time.Now()
-	return emby, nil
-}
-
-// Authenticate attempts to authenticate using a username & password
-func (emby *MediaBrowserStruct) Authenticate(username, password string) (map[string]interface{}, int, error) {
-	emby.Username = username
-	emby.password = password
-	emby.loginParams = map[string]string{
-		"Username": username,
-		"Pw":       password,
-		"Password": password,
-	}
-	buffer := &bytes.Buffer{}
-	encoder := json.NewEncoder(buffer)
-	encoder.SetEscapeHTML(false)
-	err := encoder.Encode(emby.loginParams)
-	if err != nil {
-		return nil, 0, err
-	}
-	// loginParams, _ := json.Marshal(jf.loginParams)
-	url := fmt.Sprintf("%s/Users/authenticatebyname", emby.Server)
-	req, err := http.NewRequest("POST", url, buffer)
-	defer emby.timeoutHandler()
-	if err != nil {
-		return nil, 0, err
-	}
-	for name, value := range emby.header {
-		req.Header.Add(name, value)
-	}
-	resp, err := emby.httpClient.Do(req)
-	if err != nil || resp.StatusCode != 200 {
-		return nil, resp.StatusCode, err
-	}
-	defer resp.Body.Close()
-	var data io.Reader
-	switch resp.Header.Get("Content-Encoding") {
-	case "gzip":
-		data, _ = gzip.NewReader(resp.Body)
-	default:
-		data = resp.Body
-	}
-	var respData map[string]interface{}
-	json.NewDecoder(data).Decode(&respData)
-	emby.AccessToken = respData["AccessToken"].(string)
-	user := respData["User"].(map[string]interface{})
-	emby.userID = respData["User"].(map[string]interface{})["Id"].(string)
-	emby.auth = fmt.Sprintf("MediaBrowser Client=\"%s\", Device=\"%s\", DeviceId=\"%s\", Version=\"%s\", Token=\"%s\"", emby.client, emby.device, emby.deviceID, emby.version, emby.AccessToken)
-	emby.header["X-Emby-Authorization"] = emby.auth
-	emby.Authenticated = true
-	return user, resp.StatusCode, nil
-}
-
-func (emby *MediaBrowserStruct) get(url string, params map[string]string) (string, int, error) {
-	var req *http.Request
-	if params != nil {
-		jsonParams, _ := json.Marshal(params)
-		req, _ = http.NewRequest("GET", url, bytes.NewBuffer(jsonParams))
-	} else {
-		req, _ = http.NewRequest("GET", url, nil)
-	}
-	for name, value := range emby.header {
-		req.Header.Add(name, value)
-	}
-	resp, err := emby.httpClient.Do(req)
-	defer emby.timeoutHandler()
-	if err != nil || resp.StatusCode != 200 {
-		if resp.StatusCode == 401 && emby.Authenticated {
-			emby.Authenticated = false
-			_, _, authErr := emby.Authenticate(emby.Username, emby.password)
-			if authErr == nil {
-				v1, v2, v3 := emby.get(url, params)
-				return v1, v2, v3
-			}
-		}
-		return "", resp.StatusCode, err
-	}
-	defer resp.Body.Close()
-	var data io.Reader
-	encoding := resp.Header.Get("Content-Encoding")
-	switch encoding {
-	case "gzip":
-		data, _ = gzip.NewReader(resp.Body)
-	default:
-		data = resp.Body
-	}
-	buf := new(strings.Builder)
-	io.Copy(buf, data)
-	//var respData map[string]interface{}
-	//json.NewDecoder(data).Decode(&respData)
-	return buf.String(), resp.StatusCode, nil
-}
-
-func (emby *MediaBrowserStruct) post(url string, data map[string]interface{}, response bool) (string, int, error) {
-	params, _ := json.Marshal(data)
-	req, _ := http.NewRequest("POST", url, bytes.NewBuffer(params))
-	for name, value := range emby.header {
-		req.Header.Add(name, value)
-	}
-	resp, err := emby.httpClient.Do(req)
-	defer emby.timeoutHandler()
-	if err != nil || resp.StatusCode != 200 {
-		if resp.StatusCode == 401 && emby.Authenticated {
-			emby.Authenticated = false
-			_, _, authErr := emby.Authenticate(emby.Username, emby.password)
-			if authErr == nil {
-				v1, v2, v3 := emby.post(url, data, response)
-				return v1, v2, v3
-			}
-		}
-		return "", resp.StatusCode, err
-	}
-	if response {
-		defer resp.Body.Close()
-		var outData io.Reader
-		switch resp.Header.Get("Content-Encoding") {
-		case "gzip":
-			outData, _ = gzip.NewReader(resp.Body)
-		default:
-			outData = resp.Body
-		}
-		buf := new(strings.Builder)
-		io.Copy(buf, outData)
-		return buf.String(), resp.StatusCode, nil
-	}
-	return "", resp.StatusCode, nil
-}
-
-// DeleteUser deletes the user corresponding to the provided ID.
-func (emby *MediaBrowserStruct) DeleteUser(userID string) (int, error) {
+func embyDeleteUser(emby *MediaBrowser, userID string) (int, error) {
 	url := fmt.Sprintf("%s/Users/%s", emby.Server, userID)
 	req, _ := http.NewRequest("DELETE", url, nil)
 	for name, value := range emby.header {
@@ -188,8 +20,7 @@ func (emby *MediaBrowserStruct) DeleteUser(userID string) (int, error) {
 	return resp.StatusCode, err
 }
 
-// GetUsers returns all (visible) users on the Emby instance.
-func (emby *MediaBrowserStruct) GetUsers(public bool) ([]map[string]interface{}, int, error) {
+func embyGetUsers(emby *MediaBrowser, public bool) ([]map[string]interface{}, int, error) {
 	var result []map[string]interface{}
 	var data string
 	var status int
@@ -218,8 +49,7 @@ func (emby *MediaBrowserStruct) GetUsers(public bool) ([]map[string]interface{},
 	return emby.userCache, 200, nil
 }
 
-// UserByName returns the user corresponding to the provided username.
-func (emby *MediaBrowserStruct) UserByName(username string, public bool) (map[string]interface{}, int, error) {
+func embyUserByName(emby *MediaBrowser, username string, public bool) (map[string]interface{}, int, error) {
 	var match map[string]interface{}
 	find := func() (map[string]interface{}, int, error) {
 		users, status, err := emby.GetUsers(public)
@@ -241,8 +71,7 @@ func (emby *MediaBrowserStruct) UserByName(username string, public bool) (map[st
 	return match, status, err
 }
 
-// UserByID returns the user corresponding to the provided ID.
-func (emby *MediaBrowserStruct) UserByID(userID string, public bool) (map[string]interface{}, int, error) {
+func embyUserByID(emby *MediaBrowser, userID string, public bool) (map[string]interface{}, int, error) {
 	if emby.CacheExpiry.After(time.Now()) {
 		for _, user := range emby.userCache {
 			if user["Id"].(string) == userID {
@@ -275,13 +104,12 @@ func (emby *MediaBrowserStruct) UserByID(userID string, public bool) (map[string
 	return result, status, nil
 }
 
-// NewUser creates a new user with the provided username and password.
 // Since emby doesn't allow one to specify a password on user creation, we:
 // Create the account
 // Immediately disable it
 // Set password
 // Reeenable it
-func (emby *MediaBrowserStruct) NewUser(username, password string) (map[string]interface{}, int, error) {
+func embyNewUser(emby *MediaBrowser, username, password string) (map[string]interface{}, int, error) {
 	url := fmt.Sprintf("%s/Users/New", emby.Server)
 	data := map[string]interface{}{
 		"Name": username,
@@ -294,7 +122,7 @@ func (emby *MediaBrowserStruct) NewUser(username, password string) (map[string]i
 	}
 	// Step 2: Set password
 	id := recv["Id"].(string)
-	url = fmt.Sprintf("/Users/%s/Password", id)
+	url = fmt.Sprintf("%s/Users/%s/Password", emby.Server, id)
 	data = map[string]interface{}{
 		"Id":        id,
 		"CurrentPw": "",
@@ -303,13 +131,12 @@ func (emby *MediaBrowserStruct) NewUser(username, password string) (map[string]i
 	_, status, err = emby.post(url, data, false)
 	// Step 3: If setting password errored, try to delete the account
 	if err != nil || !(status == 200 || status == 204) {
-		status, err = emby.DeleteUser(id)
+		_, err = emby.DeleteUser(id)
 	}
 	return recv, status, nil
 }
 
-// SetPolicy sets the access policy for the user corresponding to the provided ID.
-func (emby *MediaBrowserStruct) SetPolicy(userID string, policy map[string]interface{}) (int, error) {
+func embySetPolicy(emby *MediaBrowser, userID string, policy map[string]interface{}) (int, error) {
 	url := fmt.Sprintf("%s/Users/%s/Policy", emby.Server, userID)
 	_, status, err := emby.post(url, policy, false)
 	if err != nil || status != 200 {
@@ -318,15 +145,13 @@ func (emby *MediaBrowserStruct) SetPolicy(userID string, policy map[string]inter
 	return status, nil
 }
 
-// SetConfiguration sets the configuration (part of homescreen layout) for the user corresponding to the provided ID.
-func (emby *MediaBrowserStruct) SetConfiguration(userID string, configuration map[string]interface{}) (int, error) {
+func embySetConfiguration(emby *MediaBrowser, userID string, configuration map[string]interface{}) (int, error) {
 	url := fmt.Sprintf("%s/Users/%s/Configuration", emby.Server, userID)
 	_, status, err := emby.post(url, configuration, false)
 	return status, err
 }
 
-// GetDisplayPreferences gets the displayPreferences (part of homescreen layout) for the user corresponding to the provided ID.
-func (emby *MediaBrowserStruct) GetDisplayPreferences(userID string) (map[string]interface{}, int, error) {
+func embyGetDisplayPreferences(emby *MediaBrowser, userID string) (map[string]interface{}, int, error) {
 	url := fmt.Sprintf("%s/DisplayPreferences/usersettings?userId=%s&client=emby", emby.Server, userID)
 	data, status, err := emby.get(url, nil)
 	if err != nil || !(status == 204 || status == 200) {
@@ -340,8 +165,7 @@ func (emby *MediaBrowserStruct) GetDisplayPreferences(userID string) (map[string
 	return displayprefs, status, nil
 }
 
-// SetDisplayPreferences sets the displayPreferences (part of homescreen layout) for the user corresponding to the provided ID.
-func (emby *MediaBrowserStruct) SetDisplayPreferences(userID string, displayprefs map[string]interface{}) (int, error) {
+func embySetDisplayPreferences(emby *MediaBrowser, userID string, displayprefs map[string]interface{}) (int, error) {
 	url := fmt.Sprintf("%s/DisplayPreferences/usersettings?userId=%s&client=emby", emby.Server, userID)
 	_, status, err := emby.post(url, displayprefs, false)
 	if err != nil || !(status == 204 || status == 200) {

mediabrowser/jfapi.go

@@ -1,181 +1,13 @@
 package mediabrowser
 
 import (
-	"bytes"
-	"compress/gzip"
 	"encoding/json"
 	"fmt"
-	"io"
-	"io/ioutil"
 	"net/http"
-	"strings"
 	"time"
-
-	"github.com/hrfee/jfa-go/common"
 )
 
-// NewJellyfin returns a new Jellyfin object.
-func NewJellyfin(server, client, version, device, deviceID string, timeoutHandler common.TimeoutHandler, cacheTimeout int) (*MediaBrowserStruct, error) {
-	jf := &MediaBrowserStruct{}
-	jf.Server = server
-	jf.client = client
-	jf.version = version
-	jf.device = device
-	jf.deviceID = deviceID
-	jf.useragent = fmt.Sprintf("%s/%s", client, version)
-	jf.timeoutHandler = timeoutHandler
-	jf.auth = fmt.Sprintf("MediaBrowser Client=\"%s\", Device=\"%s\", DeviceId=\"%s\", Version=\"%s\"", client, device, deviceID, version)
-	jf.header = map[string]string{
-		"Accept":               "application/json",
-		"Content-type":         "application/json; charset=UTF-8",
-		"X-Application":        jf.useragent,
-		"Accept-Charset":       "UTF-8,*",
-		"Accept-Encoding":      "gzip",
-		"User-Agent":           jf.useragent,
-		"X-Emby-Authorization": jf.auth,
-	}
-	jf.httpClient = &http.Client{
-		Timeout: 10 * time.Second,
-	}
-	infoURL := fmt.Sprintf("%s/System/Info/Public", server)
-	req, _ := http.NewRequest("GET", infoURL, nil)
-	resp, err := jf.httpClient.Do(req)
-	defer jf.timeoutHandler()
-	if err == nil {
-		data, _ := ioutil.ReadAll(resp.Body)
-		json.Unmarshal(data, &jf.ServerInfo)
-	}
-	jf.cacheLength = cacheTimeout
-	jf.CacheExpiry = time.Now()
-	return jf, nil
-}
-
-// Authenticate attempts to authenticate using a username & password
-func (jf *MediaBrowserStruct) Authenticate(username, password string) (map[string]interface{}, int, error) {
-	jf.Username = username
-	jf.password = password
-	jf.loginParams = map[string]string{
-		"Username": username,
-		"Pw":       password,
-		"Password": password,
-	}
-	buffer := &bytes.Buffer{}
-	encoder := json.NewEncoder(buffer)
-	encoder.SetEscapeHTML(false)
-	err := encoder.Encode(jf.loginParams)
-	if err != nil {
-		return nil, 0, err
-	}
-	// loginParams, _ := json.Marshal(jf.loginParams)
-	url := fmt.Sprintf("%s/Users/authenticatebyname", jf.Server)
-	req, err := http.NewRequest("POST", url, buffer)
-	defer jf.timeoutHandler()
-	if err != nil {
-		return nil, 0, err
-	}
-	for name, value := range jf.header {
-		req.Header.Add(name, value)
-	}
-	resp, err := jf.httpClient.Do(req)
-	if err != nil || resp.StatusCode != 200 {
-		return nil, resp.StatusCode, err
-	}
-	defer resp.Body.Close()
-	var data io.Reader
-	switch resp.Header.Get("Content-Encoding") {
-	case "gzip":
-		data, _ = gzip.NewReader(resp.Body)
-	default:
-		data = resp.Body
-	}
-	var respData map[string]interface{}
-	json.NewDecoder(data).Decode(&respData)
-	jf.AccessToken = respData["AccessToken"].(string)
-	user := respData["User"].(map[string]interface{})
-	jf.userID = respData["User"].(map[string]interface{})["Id"].(string)
-	jf.auth = fmt.Sprintf("MediaBrowser Client=\"%s\", Device=\"%s\", DeviceId=\"%s\", Version=\"%s\", Token=\"%s\"", jf.client, jf.device, jf.deviceID, jf.version, jf.AccessToken)
-	jf.header["X-Emby-Authorization"] = jf.auth
-	jf.Authenticated = true
-	return user, resp.StatusCode, nil
-}
-
-func (jf *MediaBrowserStruct) get(url string, params map[string]string) (string, int, error) {
-	var req *http.Request
-	if params != nil {
-		jsonParams, _ := json.Marshal(params)
-		req, _ = http.NewRequest("GET", url, bytes.NewBuffer(jsonParams))
-	} else {
-		req, _ = http.NewRequest("GET", url, nil)
-	}
-	for name, value := range jf.header {
-		req.Header.Add(name, value)
-	}
-	resp, err := jf.httpClient.Do(req)
-	defer jf.timeoutHandler()
-	if err != nil || resp.StatusCode != 200 {
-		if resp.StatusCode == 401 && jf.Authenticated {
-			jf.Authenticated = false
-			_, _, authErr := jf.Authenticate(jf.Username, jf.password)
-			if authErr == nil {
-				v1, v2, v3 := jf.get(url, params)
-				return v1, v2, v3
-			}
-		}
-		return "", resp.StatusCode, err
-	}
-	defer resp.Body.Close()
-	var data io.Reader
-	encoding := resp.Header.Get("Content-Encoding")
-	switch encoding {
-	case "gzip":
-		data, _ = gzip.NewReader(resp.Body)
-	default:
-		data = resp.Body
-	}
-	buf := new(strings.Builder)
-	io.Copy(buf, data)
-	//var respData map[string]interface{}
-	//json.NewDecoder(data).Decode(&respData)
-	return buf.String(), resp.StatusCode, nil
-}
-
-func (jf *MediaBrowserStruct) post(url string, data map[string]interface{}, response bool) (string, int, error) {
-	params, _ := json.Marshal(data)
-	req, _ := http.NewRequest("POST", url, bytes.NewBuffer(params))
-	for name, value := range jf.header {
-		req.Header.Add(name, value)
-	}
-	resp, err := jf.httpClient.Do(req)
-	defer jf.timeoutHandler()
-	if err != nil || resp.StatusCode != 200 {
-		if resp.StatusCode == 401 && jf.Authenticated {
-			jf.Authenticated = false
-			_, _, authErr := jf.Authenticate(jf.Username, jf.password)
-			if authErr == nil {
-				v1, v2, v3 := jf.post(url, data, response)
-				return v1, v2, v3
-			}
-		}
-		return "", resp.StatusCode, err
-	}
-	if response {
-		defer resp.Body.Close()
-		var outData io.Reader
-		switch resp.Header.Get("Content-Encoding") {
-		case "gzip":
-			outData, _ = gzip.NewReader(resp.Body)
-		default:
-			outData = resp.Body
-		}
-		buf := new(strings.Builder)
-		io.Copy(buf, outData)
-		return buf.String(), resp.StatusCode, nil
-	}
-	return "", resp.StatusCode, nil
-}
-
-// DeleteUser deletes the user corresponding to the provided ID.
-func (jf *MediaBrowserStruct) DeleteUser(userID string) (int, error) {
+func jfDeleteUser(jf *MediaBrowser, userID string) (int, error) {
 	url := fmt.Sprintf("%s/Users/%s", jf.Server, userID)
 	req, _ := http.NewRequest("DELETE", url, nil)
 	for name, value := range jf.header {
@@ -186,8 +18,7 @@ func (jf *MediaBrowserStruct) DeleteUser(userID string) (int, error) {
 	return resp.StatusCode, err
 }
 
-// GetUsers returns all (visible) users on the Jellyfin instance.
-func (jf *MediaBrowserStruct) GetUsers(public bool) ([]map[string]interface{}, int, error) {
+func jfGetUsers(jf *MediaBrowser, public bool) ([]map[string]interface{}, int, error) {
 	var result []map[string]interface{}
 	var data string
 	var status int
@@ -216,8 +47,7 @@ func (jf *MediaBrowserStruct) GetUsers(public bool) ([]map[string]interface{}, i
 	return jf.userCache, 200, nil
 }
 
-// UserByName returns the user corresponding to the provided username.
-func (jf *MediaBrowserStruct) UserByName(username string, public bool) (map[string]interface{}, int, error) {
+func jfUserByName(jf *MediaBrowser, username string, public bool) (map[string]interface{}, int, error) {
 	var match map[string]interface{}
 	find := func() (map[string]interface{}, int, error) {
 		users, status, err := jf.GetUsers(public)
@@ -239,8 +69,7 @@ func (jf *MediaBrowserStruct) UserByName(username string, public bool) (map[stri
 	return match, status, err
 }
 
-// UserByID returns the user corresponding to the provided ID.
-func (jf *MediaBrowserStruct) UserByID(userID string, public bool) (map[string]interface{}, int, error) {
+func jfUserByID(jf *MediaBrowser, userID string, public bool) (map[string]interface{}, int, error) {
 	if jf.CacheExpiry.After(time.Now()) {
 		for _, user := range jf.userCache {
 			if user["Id"].(string) == userID {
@@ -273,8 +102,7 @@ func (jf *MediaBrowserStruct) UserByID(userID string, public bool) (map[string]i
 	return result, status, nil
 }
 
-// NewUser creates a new user with the provided username and password.
-func (jf *MediaBrowserStruct) NewUser(username, password string) (map[string]interface{}, int, error) {
+func jfNewUser(jf *MediaBrowser, username, password string) (map[string]interface{}, int, error) {
 	url := fmt.Sprintf("%s/Users/New", jf.Server)
 	stringData := map[string]string{
 		"Name":     username,
@@ -293,8 +121,7 @@ func (jf *MediaBrowserStruct) NewUser(username, password string) (map[string]int
 	return recv, status, nil
 }
 
-// SetPolicy sets the access policy for the user corresponding to the provided ID.
-func (jf *MediaBrowserStruct) SetPolicy(userID string, policy map[string]interface{}) (int, error) {
+func jfSetPolicy(jf *MediaBrowser, userID string, policy map[string]interface{}) (int, error) {
 	url := fmt.Sprintf("%s/Users/%s/Policy", jf.Server, userID)
 	_, status, err := jf.post(url, policy, false)
 	if err != nil || status != 200 {
@@ -303,15 +130,13 @@ func (jf *MediaBrowserStruct) SetPolicy(userID string, policy map[string]interfa
 	return status, nil
 }
 
-// SetConfiguration sets the configuration (part of homescreen layout) for the user corresponding to the provided ID.
-func (jf *MediaBrowserStruct) SetConfiguration(userID string, configuration map[string]interface{}) (int, error) {
+func jfSetConfiguration(jf *MediaBrowser, userID string, configuration map[string]interface{}) (int, error) {
 	url := fmt.Sprintf("%s/Users/%s/Configuration", jf.Server, userID)
 	_, status, err := jf.post(url, configuration, false)
 	return status, err
 }
 
-// GetDisplayPreferences gets the displayPreferences (part of homescreen layout) for the user corresponding to the provided ID.
-func (jf *MediaBrowserStruct) GetDisplayPreferences(userID string) (map[string]interface{}, int, error) {
+func jfGetDisplayPreferences(jf *MediaBrowser, userID string) (map[string]interface{}, int, error) {
 	url := fmt.Sprintf("%s/DisplayPreferences/usersettings?userId=%s&client=emby", jf.Server, userID)
 	data, status, err := jf.get(url, nil)
 	if err != nil || !(status == 204 || status == 200) {
@@ -325,8 +150,7 @@ func (jf *MediaBrowserStruct) GetDisplayPreferences(userID string) (map[string]i
 	return displayprefs, status, nil
 }
 
-// SetDisplayPreferences sets the displayPreferences (part of homescreen layout) for the user corresponding to the provided ID.
-func (jf *MediaBrowserStruct) SetDisplayPreferences(userID string, displayprefs map[string]interface{}) (int, error) {
+func jfSetDisplayPreferences(jf *MediaBrowser, userID string, displayprefs map[string]interface{}) (int, error) {
 	url := fmt.Sprintf("%s/DisplayPreferences/usersettings?userId=%s&client=emby", jf.Server, userID)
 	_, status, err := jf.post(url, displayprefs, false)
 	if err != nil || !(status == 204 || status == 200) {

mediabrowser/mediabrowser.go

@@ -1,10 +1,24 @@
 package mediabrowser
 
 import (
+	"bytes"
+	"compress/gzip"
+	"encoding/json"
+	"fmt"
+	"io"
+	"io/ioutil"
 	"net/http"
+	"strings"
 	"time"
+
+	"github.com/hrfee/jfa-go/common"
 )
 
+type serverType bool
+
+var JellyfinServer serverType = false
+var EmbyServer serverType = true
+
 type serverInfo struct {
 	LocalAddress string `json:"LocalAddress"`
 	Name         string `json:"ServerName"`
@@ -13,7 +27,8 @@ type serverInfo struct {
 	ID           string `json:"Id"`
 }
 
-type MediaBrowserStruct struct {
+// MediaBrowser is an api instance of Jellyfin/Emby.
+type MediaBrowser struct {
 	Server         string
 	client         string
 	version        string
@@ -35,19 +50,239 @@ type MediaBrowserStruct struct {
 	cacheLength    int
 	noFail         bool
 	Hyphens        bool
-	timeoutHandler TimeoutHandler
+	serverType     serverType
+	timeoutHandler common.TimeoutHandler
 }
 
-// MediaBrowser is an api instance of Jellyfin/Emby.
-type MediaBrowser interface {
-	Authenticate(username, password string) (map[string]interface{}, int, error)
-	DeleteUser(userID string) (int, error)
-	GetUsers(public bool) ([]map[string]interface{}, int, error)
-	UserByName(username string, public bool) (map[string]interface{}, int, error)
-	UserByID(userID string, public bool) (map[string]interface{}, int, error)
-	NewUser(username, password string) (map[string]interface{}, int, error)
-	SetPolicy(userID string, policy map[string]interface{}) (int, error)
-	SetConfiguration(userID string, configuration map[string]interface{}) (int, error)
-	GetDisplayPreferences(userID string) (map[string]interface{}, int, error)
-	SetDisplayPreferences(userID string, displayprefs map[string]interface{}) (int, error)
+// NewServer returns a new Jellyfin object.
+func NewServer(st serverType, server, client, version, device, deviceID string, timeoutHandler common.TimeoutHandler, cacheTimeout int) (*MediaBrowser, error) {
+	mb := &MediaBrowser{}
+	mb.serverType = st
+	mb.Server = server
+	mb.client = client
+	mb.version = version
+	mb.device = device
+	mb.deviceID = deviceID
+	mb.useragent = fmt.Sprintf("%s/%s", client, version)
+	mb.timeoutHandler = timeoutHandler
+	mb.auth = fmt.Sprintf("MediaBrowser Client=\"%s\", Device=\"%s\", DeviceId=\"%s\", Version=\"%s\"", client, device, deviceID, version)
+	mb.header = map[string]string{
+		"Accept":               "application/json",
+		"Content-type":         "application/json; charset=UTF-8",
+		"X-Application":        mb.useragent,
+		"Accept-Charset":       "UTF-8,*",
+		"Accept-Encoding":      "gzip",
+		"User-Agent":           mb.useragent,
+		"X-Emby-Authorization": mb.auth,
+	}
+	mb.httpClient = &http.Client{
+		Timeout: 10 * time.Second,
+	}
+	infoURL := fmt.Sprintf("%s/System/Info/Public", server)
+	req, _ := http.NewRequest("GET", infoURL, nil)
+	resp, err := mb.httpClient.Do(req)
+	defer mb.timeoutHandler()
+	if err == nil {
+		data, _ := ioutil.ReadAll(resp.Body)
+		json.Unmarshal(data, &mb.ServerInfo)
+	}
+	mb.cacheLength = cacheTimeout
+	mb.CacheExpiry = time.Now()
+	return mb, nil
+}
+
+func (mb *MediaBrowser) get(url string, params map[string]string) (string, int, error) {
+	var req *http.Request
+	if params != nil {
+		jsonParams, _ := json.Marshal(params)
+		req, _ = http.NewRequest("GET", url, bytes.NewBuffer(jsonParams))
+	} else {
+		req, _ = http.NewRequest("GET", url, nil)
+	}
+	for name, value := range mb.header {
+		req.Header.Add(name, value)
+	}
+	resp, err := mb.httpClient.Do(req)
+	defer mb.timeoutHandler()
+	if err != nil || resp.StatusCode != 200 {
+		if resp.StatusCode == 401 && mb.Authenticated {
+			mb.Authenticated = false
+			_, _, authErr := mb.Authenticate(mb.Username, mb.password)
+			if authErr == nil {
+				v1, v2, v3 := mb.get(url, params)
+				return v1, v2, v3
+			}
+		}
+		return "", resp.StatusCode, err
+	}
+	defer resp.Body.Close()
+	var data io.Reader
+	encoding := resp.Header.Get("Content-Encoding")
+	switch encoding {
+	case "gzip":
+		data, _ = gzip.NewReader(resp.Body)
+	default:
+		data = resp.Body
+	}
+	buf := new(strings.Builder)
+	io.Copy(buf, data)
+	//var respData map[string]interface{}
+	//json.NewDecoder(data).Decode(&respData)
+	return buf.String(), resp.StatusCode, nil
+}
+
+func (mb *MediaBrowser) post(url string, data map[string]interface{}, response bool) (string, int, error) {
+	params, _ := json.Marshal(data)
+	req, _ := http.NewRequest("POST", url, bytes.NewBuffer(params))
+	for name, value := range mb.header {
+		req.Header.Add(name, value)
+	}
+	resp, err := mb.httpClient.Do(req)
+	defer mb.timeoutHandler()
+	if err != nil || resp.StatusCode != 200 {
+		if resp.StatusCode == 401 && mb.Authenticated {
+			mb.Authenticated = false
+			_, _, authErr := mb.Authenticate(mb.Username, mb.password)
+			if authErr == nil {
+				v1, v2, v3 := mb.post(url, data, response)
+				return v1, v2, v3
+			}
+		}
+		return "", resp.StatusCode, err
+	}
+	if response {
+		defer resp.Body.Close()
+		var outData io.Reader
+		switch resp.Header.Get("Content-Encoding") {
+		case "gzip":
+			outData, _ = gzip.NewReader(resp.Body)
+		default:
+			outData = resp.Body
+		}
+		buf := new(strings.Builder)
+		io.Copy(buf, outData)
+		return buf.String(), resp.StatusCode, nil
+	}
+	return "", resp.StatusCode, nil
+}
+
+// Authenticate attempts to authenticate using a username & password
+func (mb *MediaBrowser) Authenticate(username, password string) (map[string]interface{}, int, error) {
+	mb.Username = username
+	mb.password = password
+	mb.loginParams = map[string]string{
+		"Username": username,
+		"Pw":       password,
+		"Password": password,
+	}
+	buffer := &bytes.Buffer{}
+	encoder := json.NewEncoder(buffer)
+	encoder.SetEscapeHTML(false)
+	err := encoder.Encode(mb.loginParams)
+	if err != nil {
+		return nil, 0, err
+	}
+	// loginParams, _ := json.Marshal(jf.loginParams)
+	url := fmt.Sprintf("%s/Users/authenticatebyname", mb.Server)
+	req, err := http.NewRequest("POST", url, buffer)
+	defer mb.timeoutHandler()
+	if err != nil {
+		return nil, 0, err
+	}
+	for name, value := range mb.header {
+		req.Header.Add(name, value)
+	}
+	resp, err := mb.httpClient.Do(req)
+	if err != nil || resp.StatusCode != 200 {
+		return nil, resp.StatusCode, err
+	}
+	defer resp.Body.Close()
+	var data io.Reader
+	switch resp.Header.Get("Content-Encoding") {
+	case "gzip":
+		data, _ = gzip.NewReader(resp.Body)
+	default:
+		data = resp.Body
+	}
+	var respData map[string]interface{}
+	json.NewDecoder(data).Decode(&respData)
+	mb.AccessToken = respData["AccessToken"].(string)
+	user := respData["User"].(map[string]interface{})
+	mb.userID = respData["User"].(map[string]interface{})["Id"].(string)
+	mb.auth = fmt.Sprintf("MediaBrowser Client=\"%s\", Device=\"%s\", DeviceId=\"%s\", Version=\"%s\", Token=\"%s\"", mb.client, mb.device, mb.deviceID, mb.version, mb.AccessToken)
+	mb.header["X-Emby-Authorization"] = mb.auth
+	mb.Authenticated = true
+	return user, resp.StatusCode, nil
+}
+
+// DeleteUser deletes the user corresponding to the provided ID.
+func (mb *MediaBrowser) DeleteUser(userID string) (int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfDeleteUser(mb, userID)
+	}
+	return embyDeleteUser(mb, userID)
+}
+
+// GetUsers returns all (visible) users on the Emby instance.
+func (mb *MediaBrowser) GetUsers(public bool) ([]map[string]interface{}, int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfGetUsers(mb, public)
+	}
+	return embyGetUsers(mb, public)
+}
+
+// UserByName returns the user corresponding to the provided username.
+func (mb *MediaBrowser) UserByName(username string, public bool) (map[string]interface{}, int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfUserByName(mb, username, public)
+	}
+	return embyUserByName(mb, username, public)
+}
+
+// UserByID returns the user corresponding to the provided ID.
+func (mb *MediaBrowser) UserByID(userID string, public bool) (map[string]interface{}, int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfUserByID(mb, userID, public)
+	}
+	return embyUserByID(mb, userID, public)
+}
+
+// NewUser creates a new user with the provided username and password.
+func (mb *MediaBrowser) NewUser(username, password string) (map[string]interface{}, int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfNewUser(mb, username, password)
+	}
+	return embyNewUser(mb, username, password)
+}
+
+// SetPolicy sets the access policy for the user corresponding to the provided ID.
+func (mb *MediaBrowser) SetPolicy(userID string, policy map[string]interface{}) (int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfSetPolicy(mb, userID, policy)
+	}
+	return embySetPolicy(mb, userID, policy)
+}
+
+// SetConfiguration sets the configuration (part of homescreen layout) for the user corresponding to the provided ID.
+func (mb *MediaBrowser) SetConfiguration(userID string, configuration map[string]interface{}) (int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfSetConfiguration(mb, userID, configuration)
+	}
+	return embySetConfiguration(mb, userID, configuration)
+}
+
+// GetDisplayPreferences gets the displayPreferences (part of homescreen layout) for the user corresponding to the provided ID.
+func (mb *MediaBrowser) GetDisplayPreferences(userID string) (map[string]interface{}, int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfGetDisplayPreferences(mb, userID)
+	}
+	return embyGetDisplayPreferences(mb, userID)
+}
+
+// SetDisplayPreferences sets the displayPreferences (part of homescreen layout) for the user corresponding to the provided ID.
+func (mb *MediaBrowser) SetDisplayPreferences(userID string, displayprefs map[string]interface{}) (int, error) {
+	if mb.serverType == JellyfinServer {
+		return jfSetDisplayPreferences(mb, userID, displayprefs)
+	}
+	return embySetDisplayPreferences(mb, userID, displayprefs)
 }