+
+
+
+
+
+ | {{user.userID}} | +{{user.alias}} | +hashed passphrase = {{user.password}} | ++ |
| # | +UUID | +Title | +Actions | +
|---|---|---|---|
| {{publication.id}} | +{{publication.uuid}} | +{{publication.title}} | ++ + + Edit + + | +
| # | +Date | +Publication | +User | +Type | +Start date | +End date | +Delivered | +Actions | +
|---|---|---|---|---|---|---|---|---|
| {{purchase.id}} | +{{formatDate(purchase.transactionDate)}} | +{{purchase.publication.title}} | +{{purchase.user.name}} | +{{purchase.type}} | +{{formatDate(purchase.startDate)}} | +{{formatDate(purchase.endDate)}} | +{{purchase.licenseUuid != null}} | +
+
+
+
+ Status
+
+
+ Renew
+
+
+
+ |
+
| # | +Name | +Actions | +|
|---|---|---|---|
| {{user.id}} | +{{user.name}} | +{{user.email}} | ++ + + Edit + + | +
+// for standard http error messages use "about:blank" status in json equals http status
+import (
+ "strings"
+ "log"
+ "encoding/json"
+ "fmt"
+ "net/http"
+ "runtime/debug"
+
+ "github.com/technoweenie/grohl"
+
+ "github.com/readium/readium-lcp-server/localization"
+)
+
+const (
+ ContentType_PROBLEM_JSON = "application/problem+json"
+)
+
+type Problem struct {
+ Type string `json:"type,omitempty"`
+ //optionnal
+ Title string `json:"title,omitempty"`
+ Status int `json:"status,omitempty"` //if present = http response code
+ Detail string `json:"detail,omitempty"`
+ Instance string `json:"instance,omitempty"`
+ //Additional members
+}
+
+const ERROR_BASE_URL = "http://readium.org/license-status-document/error/"
+const SERVER_INTERNAL_ERROR = ERROR_BASE_URL + "server"
+const REGISTRATION_BAD_REQUEST = ERROR_BASE_URL + "registration"
+const RETURN_BAD_REQUEST = ERROR_BASE_URL + "return"
+const RENEW_BAD_REQUEST = ERROR_BASE_URL + "renew"
+const RENEW_REJECT = ERROR_BASE_URL + "renew/date"
+const CANCEL_BAD_REQUEST = ERROR_BASE_URL + "cancel"
+const FILTER_BAD_REQUEST = ERROR_BASE_URL + "filter"
+
+func Error(w http.ResponseWriter, r *http.Request, problem Problem, status int) {
+ acceptLanguages := r.Header.Get("Accept-Language")
+
+ w.Header().Set("Content-Type", ContentType_PROBLEM_JSON)
+ w.Header().Set("X-Content-Type-Options", "nosniff")
+
+ // must come *after* w.Header().Add()/Set(), but before w.Write()
+ w.WriteHeader(status)
+
+ problem.Status = status
+
+ if problem.Type == "about:blank" || problem.Type == "" { // lookup Title statusText should match http status
+ localization.LocalizeMessage(acceptLanguages, &problem.Title, http.StatusText(status))
+ } else {
+ localization.LocalizeMessage(acceptLanguages, &problem.Title, problem.Title)
+ localization.LocalizeMessage(acceptLanguages, &problem.Detail, problem.Detail)
+ }
+ jsonError, e := json.Marshal(problem)
+ if e != nil {
+ http.Error(w, "{}", problem.Status)
+ }
+ fmt.Fprintln(w, string(jsonError))
+
+ PrintStack()
+
+ log.Print(string(jsonError))
+}
+
+func PrintStack() {
+ log.Print("####################")
+
+ //debug.PrintStack()
+
+ b := debug.Stack()
+ s := string(b[:])
+ l := strings.Index(s, "ServeHTTP")
+ if l > 0 {
+ ss := s[0:l]
+ log.Print(ss + " [...]")
+ } else {
+ log.Print(s)
+ }
+
+ log.Print("####################")
+}
+
+func NotFoundHandler(w http.ResponseWriter, r *http.Request) {
+ grohl.Log(grohl.Data{"method": r.Method, "path": r.URL.Path, "status": "404"})
+ Error(w, r, Problem{}, http.StatusNotFound)
+}
+
+func PanicReport(err interface{}) {
+ switch t := err.(type) {
+ case error:
+ errorr, found := err.(error)
+ if found { // should always be true
+ grohl.Log(grohl.Data{"panic recovery (error)": errorr.Error()})
+ }
+ case string:
+ errorr, found := err.(string)
+ if found { // should always be true
+ grohl.Log(grohl.Data{"panic recovery (string)": errorr})
+ }
+ default:
+ grohl.Log(grohl.Data{"panic recovery (other type)": t})
+ }
+}
diff --git a/server/api/license.go b/server/api/license.go
deleted file mode 100644
index 83e186b7..00000000
--- a/server/api/license.go
+++ /dev/null
@@ -1,212 +0,0 @@
-package api
-
-import (
- "archive/zip"
- "bytes"
- "crypto/sha256"
- "crypto/tls"
- "encoding/base64"
- "encoding/json"
- "fmt"
- "reflect"
- "strings"
-
- "github.com/gorilla/mux"
- "github.com/readium/readium-lcp-server/crypto"
- "github.com/readium/readium-lcp-server/epub"
- "github.com/readium/readium-lcp-server/license"
- "github.com/readium/readium-lcp-server/sign"
-
- "io"
- "net/http"
-)
-
-//{
-//"content_key": "12345",
-//"date": "2013-11-04T01:08:15+01:00",
-//"hint": "Enter your email address",
-//"hint_url": "http://www.imaginaryebookretailer.com/lcp"
-//}
-
-func GrantLicense(w http.ResponseWriter, r *http.Request, s Server) {
- vars := mux.Vars(r)
- var lic license.License
- var dec *json.Decoder
- if ctype := r.Header["Content-Type"]; len(ctype) > 0 && ctype[0] == "application/x-www-form-urlencoded" {
- buf := bytes.NewBufferString(r.PostFormValue("data"))
- dec = json.NewDecoder(buf)
- } else {
- dec = json.NewDecoder(r.Body)
- }
- err := dec.Decode(&lic)
- if err != nil {
- http.Error(w, err.Error(), http.StatusBadRequest)
- return
- }
- if _, hintFound := lic.Links["hint"]; !hintFound {
- http.Error(w, "hint url not set", http.StatusBadRequest)
- return
- }
-
- mode := r.PostFormValue("type")
- key := vars["key"]
- if mode == "embedded" {
- item, err := s.Store().Get(key)
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
-
- indexItem, err := s.Index().Get(key)
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
- var b bytes.Buffer
- contents, err := item.Contents()
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
-
- io.Copy(&b, contents)
- zr, err := zip.NewReader(bytes.NewReader(b.Bytes()), int64(b.Len()))
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
- ep, err := epub.Read(zr)
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
- var buf bytes.Buffer
- err = grantLicense(&lic, key, false, s, &buf)
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
-
- err = s.Licenses().Add(lic)
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
-
- ep.Add("META-INF/license.lcpl", &buf, uint64(buf.Len()))
- w.Header().Add("Content-Type", "application/epub+zip")
- w.Header().Add("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, indexItem.Filename))
- ep.Write(w)
-
- } else {
- w.Header().Add("Content-Type", "application/vnd.readium.lcp.license.1-0+json")
- w.Header().Add("Content-Disposition", `attachment; filename="license.lcpl"`)
- err = grantLicense(&lic, key, false, s, w)
- if err != nil {
- http.Error(w, err.Error(), http.StatusInternalServerError)
- return
- }
- }
-}
-
-func grantLicense(l *license.License, key string, embedded bool, s Server, w io.Writer) error {
- p, err := s.Index().Get(key)
- if err != nil {
- return err
- }
-
- item, err := s.Store().Get(key)
- if err != nil {
- return err
- }
-
- license.Prepare(l)
-
- var encryptionKey []byte
- if len(l.Encryption.UserKey.Value) > 0 {
- encryptionKey = l.Encryption.UserKey.Value
- l.Encryption.UserKey.Value = nil
- } else {
- passphrase := l.Encryption.UserKey.ClearValue
- l.Encryption.UserKey.ClearValue = ""
- hash := sha256.Sum256([]byte(passphrase))
- encryptionKey = hash[:]
- }
-
- l.Encryption.ContentKey.Algorithm = "http://www.w3.org/2001/04/xmlenc#aes256-cbc"
- l.Encryption.ContentKey.Value = encryptKey(p.EncryptionKey, encryptionKey[:])
-
- l.Encryption.UserKey.Algorithm = "http://www.w3.org/2001/04/xmlenc#sha256"
- l.Encryption.UserKey.Hint = "Enter your passphrase"
-
- if !embedded {
- l.Links["publication"] = license.Link{Href: item.PublicUrl(), Type: "application/epub+zip"}
- }
-
- err = encryptFields(l, encryptionKey[:])
- if err != nil {
- return err
- }
- err = buildKeyCheck(l, encryptionKey[:])
- if err != nil {
- return err
- }
- err = signLicense(l, s.Certificate())
- if err != nil {
- return err
- }
-
- enc := json.NewEncoder(w)
- enc.Encode(l)
-
- return nil
-}
-
-func buildKeyCheck(l *license.License, key []byte) error {
- var out bytes.Buffer
- err := crypto.Encrypt(key, bytes.NewBufferString(l.Id), &out)
- if err != nil {
- return err
- }
- l.Encryption.UserKey.Check = out.Bytes()
- return nil
-}
-
-func encryptFields(l *license.License, key []byte) error {
- for _, toEncrypt := range l.User.Encrypted {
- var out bytes.Buffer
- field := getField(&l.User, toEncrypt)
- err := crypto.Encrypt(key[:], bytes.NewBufferString(field.String()), &out)
- if err != nil {
- return err
- }
- field.Set(reflect.ValueOf(base64.StdEncoding.EncodeToString(out.Bytes())))
- }
- return nil
-}
-
-func getField(u *license.UserInfo, field string) reflect.Value {
- v := reflect.ValueOf(u).Elem()
- return v.FieldByName(strings.Title(field))
-}
-
-func signLicense(l *license.License, cert *tls.Certificate) error {
- sig, err := sign.NewSigner(cert)
- if err != nil {
- return err
- }
- res, err := sig.Sign(l)
- if err != nil {
- return err
- }
- l.Signature = &res
-
- return nil
-}
-
-func encryptKey(key []byte, kek []byte) []byte {
- var out bytes.Buffer
- in := bytes.NewReader(key)
- crypto.Encrypt(kek[:], in, &out)
- return out.Bytes()
-}
diff --git a/server/api/store.go b/server/api/store.go
deleted file mode 100644
index f29c06cf..00000000
--- a/server/api/store.go
+++ /dev/null
@@ -1,87 +0,0 @@
-package api
-
-import (
- "crypto/tls"
- "encoding/json"
- "io"
- "io/ioutil"
- "os"
-
- "github.com/gorilla/mux"
- "github.com/readium/readium-lcp-server/index"
- "github.com/readium/readium-lcp-server/license"
- "github.com/readium/readium-lcp-server/pack"
- "github.com/readium/readium-lcp-server/storage"
-
- "net/http"
-)
-
-type Server interface {
- Store() storage.Store
- Index() index.Index
- Licenses() license.Store
- Certificate() *tls.Certificate
- Source() *pack.ManualSource
-}
-
-func writeRequestFileToTemp(r io.Reader) (int64, *os.File, error) {
- dir := os.TempDir()
- file, err := ioutil.TempFile(dir, "readium-lcp")
- if err != nil {
- return 0, file, err
- }
-
- n, err := io.Copy(file, r)
-
- // Rewind to the beginning of the file
- file.Seek(0, 0)
-
- return n, file, err
-}
-
-func cleanupTemp(f *os.File) {
- if f == nil {
- return
- }
- f.Close()
- os.Remove(f.Name())
-}
-
-func StorePackage(w http.ResponseWriter, r *http.Request, s Server) {
- vars := mux.Vars(r)
-
- size, f, err := writeRequestFileToTemp(r.Body)
- if err != nil {
- http.Error(w, err.Error(), http.StatusBadRequest)
- return
- }
-
- defer cleanupTemp(f)
-
- t := pack.NewTask(vars["name"], f, size)
- result := s.Source().Post(t)
-
- if result.Error != nil {
- http.Error(w, result.Error.Error(), http.StatusBadRequest)
- return
- }
-
- w.WriteHeader(200)
- json.NewEncoder(w).Encode(result.Id)
-}
-
-func ListPackages(w http.ResponseWriter, r *http.Request, s Server) {
- fn := s.Index().List()
- packages := make([]index.Package, 0)
-
- for it, err := fn(); err == nil; it, err = fn() {
- packages = append(packages, it)
- }
-
- enc := json.NewEncoder(w)
- err := enc.Encode(packages)
- if err != nil {
- http.Error(w, err.Error(), http.StatusBadRequest)
- }
-
-}
diff --git a/server/server.go b/server/server.go
deleted file mode 100644
index cee9ce11..00000000
--- a/server/server.go
+++ /dev/null
@@ -1,99 +0,0 @@
-package server
-
-import (
- "crypto/tls"
- "path/filepath"
-
- "github.com/gorilla/mux"
- "github.com/readium/readium-lcp-server/index"
- "github.com/readium/readium-lcp-server/license"
- "github.com/readium/readium-lcp-server/pack"
- "github.com/readium/readium-lcp-server/server/api"
- "github.com/readium/readium-lcp-server/storage"
- "github.com/technoweenie/grohl"
-
- "html/template"
- "net/http"
-)
-
-type Server struct {
- http.Server
- readonly bool
- idx *index.Index
- st *storage.Store
- lst *license.Store
- router *mux.Router
- cert *tls.Certificate
- source pack.ManualSource
-}
-
-func (s *Server) Store() storage.Store {
- return *s.st
-}
-
-func (s *Server) Index() index.Index {
- return *s.idx
-}
-
-func (s *Server) Licenses() license.Store {
- return *s.lst
-}
-
-func (s *Server) Certificate() *tls.Certificate {
- return s.cert
-}
-
-func (s *Server) Source() *pack.ManualSource {
- return &s.source
-}
-
-func New(bindAddr string, tplPath string, readonly bool, idx *index.Index, st *storage.Store, lst *license.Store, cert *tls.Certificate, packager *pack.Packager) *Server {
- r := mux.NewRouter()
- s := &Server{
- Server: http.Server{
- Handler: r,
- Addr: bindAddr,
- },
- readonly: readonly,
- idx: idx,
- st: st,
- lst: lst,
- cert: cert,
- router: r,
- source: pack.ManualSource{},
- }
-
- s.source.Feed(packager.Incoming)
-
- manageIndex, err := template.ParseFiles(filepath.Join(tplPath, "/manage/index.html"))
- if err != nil {
- panic(err)
- }
- r.HandleFunc("/manage/", func(w http.ResponseWriter, r *http.Request) {
- manageIndex.Execute(w, map[string]interface{}{})
- })
- r.Handle("/manage/{file}", http.FileServer(http.Dir("static")))
-
- r.Handle("/files/{file}", http.StripPrefix("/files/", http.FileServer(http.Dir("files"))))
- if !readonly {
- s.handleFunc("/api/store/{name}", api.StorePackage).Methods("POST")
- }
- s.handleFunc("/api/packages", api.ListPackages).Methods("GET")
- s.handleFunc("/api/packages/{key}/licenses", api.GrantLicense).Methods("POST")
- r.Handle("/", http.NotFoundHandler())
-
- return s
-}
-
-type HandlerFunc func(w http.ResponseWriter, r *http.Request, s api.Server)
-
-func (s *Server) handleFunc(route string, fn HandlerFunc) *mux.Route {
- return s.router.HandleFunc(route, func(w http.ResponseWriter, r *http.Request) {
- grohl.Log(grohl.Data{"path": r.URL.Path})
-
- // Add CORS
- w.Header().Add("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
- w.Header().Add("Access-Control-Allow-Origin", "*")
- fn(w, r, s)
- })
-}
diff --git a/server/server_test.go b/server/server_test.go
deleted file mode 100644
index 3e9856b4..00000000
--- a/server/server_test.go
+++ /dev/null
@@ -1,8 +0,0 @@
-package server
-
-import (
- "testing"
-)
-
-func TestSetup(t *testing.T) {
-}
diff --git a/sign/canon.go b/sign/canon.go
index ef6553ab..1191bbd2 100644
--- a/sign/canon.go
+++ b/sign/canon.go
@@ -1,6 +1,33 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package sign
import "encoding/json"
+import "strings"
+import "io"
func Canon(in interface{}) ([]byte, error) {
// the easiest way to canonicalize is to marshal it and reify it as a map
@@ -10,12 +37,17 @@ func Canon(in interface{}) ([]byte, error) {
return b, err
}
- temp := new(map[string]interface{})
+ var jsonObj interface{} // map[string]interface{} ==> auto sorting
- err = json.Unmarshal(b, temp)
- if err != nil {
- return b, err
+ dec := json.NewDecoder(strings.NewReader(string(b)))
+ dec.UseNumber()
+ for {
+ if er := dec.Decode(&jsonObj); er == io.EOF {
+ break
+ } else if er != nil {
+ return nil, er
+ }
}
- return json.Marshal(temp)
+ return json.Marshal(jsonObj)
}
diff --git a/sign/canon_test.go b/sign/canon_test.go
index 319be2c6..01295fb6 100644
--- a/sign/canon_test.go
+++ b/sign/canon_test.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package sign
import (
diff --git a/sign/sign.go b/sign/sign.go
index ccc381f9..db05aabd 100644
--- a/sign/sign.go
+++ b/sign/sign.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package sign
import (
diff --git a/sign/sign_test.go b/sign/sign_test.go
index 6bf56000..8492bbb5 100644
--- a/sign/sign_test.go
+++ b/sign/sign_test.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package sign
import (
diff --git a/static/manage/index.html b/static/manage/index.html
deleted file mode 100644
index 8f2b53c4..00000000
--- a/static/manage/index.html
+++ /dev/null
@@ -1,198 +0,0 @@
-
-
-
-
-
-
-
-
-
- LCPServer Admin
-
- Packages
-
-
-
- Emit a License
-
-
-
diff --git a/status/status.go b/status/status.go
new file mode 100644
index 00000000..fd3e12cc
--- /dev/null
+++ b/status/status.go
@@ -0,0 +1,98 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+package status
+
+import (
+ "strconv"
+ "strings"
+)
+
+const (
+ STATUS_READY = "ready"
+ STATUS_ACTIVE = "active"
+ STATUS_REVOKED = "revoked"
+ STATUS_RETURNED = "returned"
+ STATUS_CANCELLED = "cancelled"
+ STATUS_EXPIRED = "expired"
+
+ TYPE_REGISTER = "register"
+ TYPE_RETURN = "return"
+ TYPE_RENEW = "renew"
+)
+
+var statuses = map[int]string{
+ 0: STATUS_READY,
+ 1: STATUS_ACTIVE,
+ 2: STATUS_REVOKED,
+ 3: STATUS_RETURNED,
+ 4: STATUS_CANCELLED,
+ 5: STATUS_EXPIRED,
+}
+
+var Types = map[int]string{
+ 1: TYPE_REGISTER,
+ 2: TYPE_RETURN,
+ 3: TYPE_RENEW,
+}
+
+//GetStatus translate status number to status string
+func GetStatus(statusDB int64, status *string) {
+ resultStr := reverse(strconv.FormatInt(statusDB, 2))
+
+ if count := strings.Count(resultStr, "1"); count == 1 {
+ index := strings.Index(resultStr, "1")
+
+ if len(statuses) >= index+1 {
+ *status = statuses[index]
+ }
+ }
+}
+
+//SetStatus translate status string to status number
+func SetStatus(status string) (int64, error) {
+ reg := make([]string, len(statuses))
+
+ for key := range statuses {
+ if statuses[key] == status {
+ reg[key] = "1"
+ } else {
+ reg[key] = "0"
+ }
+ }
+
+ resultStr := reverse(strings.Join(reg[:], ""))
+
+ statusDB, err := strconv.ParseInt(resultStr, 2, 64)
+ return statusDB, err
+}
+
+func reverse(s string) string {
+ r := []rune(s)
+ for i, j := 0, len(r)-1; i < len(r)/2; i, j = i+1, j-1 {
+ r[i], r[j] = r[j], r[i]
+ }
+ return string(r)
+}
diff --git a/storage/fs.go b/storage/fs.go
index 17de5170..e29e3c87 100644
--- a/storage/fs.go
+++ b/storage/fs.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package storage
import (
diff --git a/storage/fs_test.go b/storage/fs_test.go
index 0b80a713..feb1c690 100644
--- a/storage/fs_test.go
+++ b/storage/fs_test.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package storage
import (
diff --git a/storage/interface.go b/storage/interface.go
index 242c5163..d080fd99 100644
--- a/storage/interface.go
+++ b/storage/interface.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package storage
import (
diff --git a/storage/s3.go b/storage/s3.go
index 566ba331..56f552af 100644
--- a/storage/s3.go
+++ b/storage/s3.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package storage
import (
diff --git a/tools/compliance_tests_tool/compliance_tests_tool.go b/tools/compliance_tests_tool/compliance_tests_tool.go
new file mode 100644
index 00000000..7881d7b8
--- /dev/null
+++ b/tools/compliance_tests_tool/compliance_tests_tool.go
@@ -0,0 +1,90 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+//This tool is for testers to control and log the tests
+package main
+
+import (
+ "flag"
+ "fmt"
+ "log"
+ "net/http"
+ "os"
+ "strconv"
+ "strings"
+ "time"
+)
+
+func main() {
+ lsdPublicBaseUrl := flag.String("lsdPublicBaseUrl", "", "public base url of lsd server")
+ flag.Parse()
+
+ var testNumber string
+ var result string
+
+ for {
+ fmt.Println("Enter the number of test, 'q' for quit the tool")
+ fmt.Scanln(&testNumber)
+
+ if strings.EqualFold(testNumber, "q") {
+ os.Exit(0)
+ }
+
+ notifyLsdServer(testNumber, "", "start", *lsdPublicBaseUrl)
+
+ for {
+ fmt.Println("Enter the result of test ('e' if test has errors, 's' if test has success)")
+ fmt.Scanln(&result)
+
+ if strings.EqualFold(result, "e") || strings.EqualFold(result, "s") {
+ notifyLsdServer(testNumber, result, "end", *lsdPublicBaseUrl)
+ break
+ }
+ }
+ }
+}
+
+func notifyLsdServer(testNumber string, result string, testStage string, publicBaseUrl string) {
+ var lsdClient = &http.Client{
+ Timeout: time.Second * 10,
+ }
+
+ req, err := http.NewRequest("GET", publicBaseUrl+"/compliancetest", nil)
+ q := req.URL.Query()
+ q.Add("test_stage", testStage)
+ q.Add("test_number", testNumber)
+ q.Add("test_result", result)
+ req.URL.RawQuery = q.Encode()
+
+ response, err := lsdClient.Do(req)
+
+ if err != nil {
+ log.Println("Error Notify LsdServer of compliancetest: " + err.Error())
+ } else {
+ if response.StatusCode != 200 {
+ log.Println("Notify LsdServer of compliancetest = " + strconv.Itoa(response.StatusCode))
+ }
+ }
+}
diff --git a/tools/logs_parser/logs_parser.go b/tools/logs_parser/logs_parser.go
new file mode 100644
index 00000000..ddab31e3
--- /dev/null
+++ b/tools/logs_parser/logs_parser.go
@@ -0,0 +1,58 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+package main
+
+import (
+ "flag"
+ "fmt"
+
+ "github.com/readium/readium-lcp-server/logging"
+)
+
+func main() {
+ logFilePath := flag.String("logfilepath", "", "path to .log file")
+ parsedFilePath := flag.String("parsedfilepath", "", "path to .log file")
+
+ fmt.Println(parsedFilePath)
+
+ flag.Parse()
+
+ err := logging.Init(*logFilePath, true)
+ if err != nil {
+ panic(err)
+ }
+
+ fmt.Println("Parsing log file...")
+ logs, err := logging.ReadLogs(*logFilePath)
+ summary, err := logging.CountTotal(logs)
+
+ if err != nil {
+ panic(err)
+ }
+
+ fmt.Println(logs)
+ fmt.Println(summary)
+}
diff --git a/transactions/transactions.go b/transactions/transactions.go
new file mode 100644
index 00000000..347e7c60
--- /dev/null
+++ b/transactions/transactions.go
@@ -0,0 +1,202 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+package transactions
+
+import (
+ "database/sql"
+ "errors"
+ "time"
+
+ "github.com/readium/readium-lcp-server/status"
+)
+
+var NotFound = errors.New("Event not found")
+
+type Transactions interface {
+ Get(id int) (Event, error)
+ Add(e Event, typeEvent int) error
+ GetByLicenseStatusId(licenseStatusFk int) func() (Event, error)
+ CheckDeviceStatus(licenseStatusFk int, deviceId string) (string, error)
+ ListRegisteredDevices(licenseStatusFk int) func() (Device, error)
+}
+
+type RegisteredDevicesList struct {
+ Id string `json:"id"`
+ Devices []Device `json:"devices"`
+}
+
+type Device struct {
+ DeviceId string `json:"id"`
+ DeviceName string `json:"name"`
+ Timestamp time.Time `json:"timestamp"`
+}
+
+type Event struct {
+ Id int `json:"-"`
+ DeviceName string `json:"name"`
+ Timestamp time.Time `json:"timestamp"`
+ Type string `json:"type"`
+ DeviceId string `json:"id"`
+ LicenseStatusFk int `json:"-"`
+}
+
+type dbTransactions struct {
+ db *sql.DB
+ get *sql.Stmt
+ add *sql.Stmt
+ getbylicensestatusid *sql.Stmt
+ checkdevicestatus *sql.Stmt
+ listregistereddevices *sql.Stmt
+}
+
+//Get returns event if it exists in table 'event'
+func (i dbTransactions) Get(id int) (Event, error) {
+ records, err := i.get.Query(id)
+ var typeInt int
+
+ defer records.Close()
+ if records.Next() {
+ var e Event
+ err = records.Scan(&e.Id, &e.DeviceName, &e.Timestamp, &typeInt, &e.DeviceId, &e.LicenseStatusFk)
+ if err == nil {
+ e.Type = status.Types[typeInt]
+ }
+ return e, err
+ }
+
+ return Event{}, NotFound
+}
+
+//Add adds event in database, parameter typeEvent is for field 'type' in table 'event'
+//1 when register device, 2 when return and 3 when renew
+func (i dbTransactions) Add(e Event, typeEvent int) error {
+ add, err := i.db.Prepare("INSERT INTO event (device_name, timestamp, type, device_id, license_status_fk) VALUES (?, ?, ?, ?, ?)")
+
+ if err != nil {
+ return err
+ }
+
+ defer add.Close()
+ _, err = add.Exec(e.DeviceName, e.Timestamp, typeEvent, e.DeviceId, e.LicenseStatusFk)
+ return err
+}
+
+//GetByLicenseStatusId returns all events by licensestatus id
+func (i dbTransactions) GetByLicenseStatusId(licenseStatusFk int) func() (Event, error) {
+ rows, err := i.getbylicensestatusid.Query(licenseStatusFk)
+ if err != nil {
+ return func() (Event, error) { return Event{}, err }
+ }
+ return func() (Event, error) {
+ var e Event
+ var err error
+ if rows.Next() {
+ err = rows.Scan(&e.Id, &e.DeviceName, &e.Timestamp, &e.Type, &e.DeviceId, &e.LicenseStatusFk)
+ } else {
+ rows.Close()
+ err = NotFound
+ }
+ return e, err
+ }
+}
+
+//ListRegisteredDevices returns all devices which has status 'regitered' by licensestatus id
+func (i dbTransactions) ListRegisteredDevices(licenseStatusFk int) func() (Device, error) {
+ rows, err := i.listregistereddevices.Query(licenseStatusFk)
+ if err != nil {
+ return func() (Device, error) { return Device{}, err }
+ }
+ return func() (Device, error) {
+ var d Device
+ var err error
+ if rows.Next() {
+ err = rows.Scan(&d.DeviceId, &d.DeviceName, &d.Timestamp)
+ } else {
+ rows.Close()
+ err = NotFound
+ }
+ return d, err
+ }
+}
+
+//CheckDeviceStatus gets current status of device
+//if there is no device in table 'event' by deviceId, typeString will be the empty string
+func (i dbTransactions) CheckDeviceStatus(licenseStatusFk int, deviceId string) (string, error) {
+ var typeString string
+ var typeInt int
+
+ row := i.checkdevicestatus.QueryRow(licenseStatusFk, deviceId)
+ err := row.Scan(&typeInt)
+
+ if err == nil {
+ typeString = status.Types[typeInt]
+ } else {
+ if err == sql.ErrNoRows {
+ return typeString, nil
+ }
+ }
+
+ return typeString, err
+}
+
+//Open defines scripts for queries & create table 'event' if not exist
+func Open(db *sql.DB) (t Transactions, err error) {
+ _, err = db.Exec(tableDef)
+ if err != nil {
+ return
+ }
+ get, err := db.Prepare("SELECT * FROM event WHERE id = ? LIMIT 1")
+ if err != nil {
+ return
+ }
+
+ getbylicensestatusid, err := db.Prepare("SELECT * FROM event WHERE license_status_fk = ?")
+
+ checkdevicestatus, err := db.Prepare(`SELECT type FROM event WHERE license_status_fk = ?
+ AND device_id = ? ORDER BY timestamp DESC LIMIT 1`)
+
+ listregistereddevices, err := db.Prepare(`SELECT device_id,
+ device_name, timestamp FROM event WHERE license_status_fk = ? AND type = 1`)
+
+ if err != nil {
+ return
+ }
+
+ t = dbTransactions{db, get, nil, getbylicensestatusid, checkdevicestatus, listregistereddevices}
+ return
+}
+
+const tableDef = `CREATE TABLE IF NOT EXISTS event (
+ id INTEGER PRIMARY KEY,
+ device_name varchar(255) DEFAULT NULL,
+ timestamp datetime NOT NULL,
+ type int NOT NULL,
+ device_id varchar(255) DEFAULT NULL,
+ license_status_fk int NOT NULL,
+ FOREIGN KEY(license_status_fk) REFERENCES license_status(id)
+);
+CREATE INDEX IF NOT EXISTS license_status_fk_index on event (license_status_fk);
+`
diff --git a/transactions/transactions_test.go b/transactions/transactions_test.go
new file mode 100644
index 00000000..196ecdef
--- /dev/null
+++ b/transactions/transactions_test.go
@@ -0,0 +1,59 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+package transactions
+
+import (
+ "database/sql"
+ "testing"
+ "time"
+
+ _ "github.com/mattn/go-sqlite3"
+
+ "github.com/readium/readium-lcp-server/status"
+)
+
+//TestTransactionCreation opens database and tries to add an event to table 'event'
+func TestTransactionCreation(t *testing.T) {
+ db, err := sql.Open("sqlite3", ":memory:")
+ trns, err := Open(db)
+ if err != nil {
+ t.Error("Can't open transactions")
+ t.Error(err)
+ t.FailNow()
+ }
+
+ timestamp := time.Now()
+
+ e := Event{DeviceName: "testdevice", Timestamp: timestamp, Type: status.Types[1], DeviceId: "deviceid", LicenseStatusFk: 1}
+ err = trns.Add(e, 1)
+ if err != nil {
+ t.Error(err)
+ }
+ _, err = trns.Get(1)
+ if err != nil {
+ t.Error(err)
+ }
+}
diff --git a/xmlenc/encryption.go b/xmlenc/encryption.go
index d5811c41..398daa58 100644
--- a/xmlenc/encryption.go
+++ b/xmlenc/encryption.go
@@ -1,3 +1,28 @@
+// Copyright (c) 2016 Readium Foundation
+//
+// Redistribution and use in source and binary forms, with or without modification,
+// are permitted provided that the following conditions are met:
+//
+// 1. Redistributions of source code must retain the above copyright notice, this
+// list of conditions and the following disclaimer.
+// 2. Redistributions in binary form must reproduce the above copyright notice,
+// this list of conditions and the following disclaimer in the documentation and/or
+// other materials provided with the distribution.
+// 3. Neither the name of the organization nor the names of its contributors may be
+// used to endorse or promote products derived from this software without specific
+// prior written permission
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
package xmlenc
import (