5 Commits

Author SHA1 Message Date
70900ea2c7 Move keyed items to v3 2020-06-15 20:32:07 -04:00
322e908147 Force new version 2020-06-14 05:42:18 -04:00
308f853b81 Push to repo first, don't upload in build step 2020-06-14 05:19:17 -04:00
d5de8568dd Force rebuild with right arch flag 2020-06-14 05:15:10 -04:00
8b80a73452 Add keyed ratings 2020-06-14 02:12:26 -04:00
6 changed files with 102 additions and 15 deletions

View File

@ -24,7 +24,6 @@ steps:
- ARCH=amd64 packaging/build-package.sh
- ARCH=armv7 packaging/build-package.sh
- ARCH=arm64 packaging/build-package.sh
- packaging/package-upload.sh
volumes:
- name: build
path: /build
@ -44,6 +43,17 @@ steps:
environment:
PLUGIN_API_KEY:
from_secret: gitea_token
- name: repo
image: tystuyfzand/drone-deb-simple
volumes:
- name: build
path: /build
settings:
url:
from_secret: upload_url
key:
from_secret: upload_key
files: [ '/build/*/owapi_*.deb' ]
volumes:
- name: build

View File

@ -12,7 +12,7 @@ import (
)
func stats(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
data, err := statsResponse(w, ps, nil)
data, err := statsResponse(w, r, ps, nil)
if err != nil {
writeError(w, err)
@ -25,7 +25,7 @@ func stats(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
}
func profile(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
cacheKey := generateCacheKey(ps) + "-profile"
cacheKey := generateCacheKey(r, ps) + "-profile"
res, err := cacheProvider.Get(cacheKey)
@ -36,7 +36,7 @@ func profile(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
}
// Cache result for profile specifically
data, err := statsResponse(w, ps, profilePatch)
data, err := statsResponse(w, r, ps, profilePatch)
if err != nil {
writeError(w, err)
@ -63,7 +63,7 @@ func heroes(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
sort.Strings(names)
cacheKey := generateCacheKey(ps) + "-heroes-" + hex.EncodeToString(md5.New().Sum([]byte(strings.Join(names, ","))))
cacheKey := generateCacheKey(r, ps) + "-heroes-" + hex.EncodeToString(md5.New().Sum([]byte(strings.Join(names, ","))))
res, err := cacheProvider.Get(cacheKey)
@ -108,7 +108,7 @@ func heroes(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
}
// Create a patch to remove all but specified heroes
data, err := statsResponse(w, ps, patch)
data, err := statsResponse(w, r, ps, patch)
if err != nil {
writeError(w, err)

1
go.mod
View File

@ -10,5 +10,6 @@ require (
github.com/julienschmidt/httprouter v1.3.0
github.com/miekg/dns v1.1.26
github.com/rs/cors v1.7.0
golang.org/x/net v0.0.0-20190923162816-aa69164e4478
s32x.com/ovrstat v0.0.0-20200131231416-4cb42edd331d
)

88
main.go
View File

@ -4,10 +4,12 @@ import (
"encoding/json"
"errors"
"flag"
"fmt"
"git.meow.tf/ow-api/ow-api/cache"
"git.meow.tf/ow-api/ow-api/json-patch"
"github.com/julienschmidt/httprouter"
"github.com/rs/cors"
"golang.org/x/net/context"
"log"
"net/http"
"regexp"
@ -17,12 +19,20 @@ import (
)
const (
Version = "2.3.4"
Version = "2.3.9"
OpAdd = "add"
OpRemove = "remove"
)
type ApiVersion int
const (
VersionOne ApiVersion = iota
VersionTwo
VersionThree
)
type gamesStats struct {
Played int64 `json:"played"`
Won int64 `json:"won"`
@ -115,10 +125,14 @@ func registerVersionTwo(router *httprouter.Router) {
router.GET("/v2/stats/"+platform+"/:tag/heroes/:heroes", injectPlatform(platform, heroes))
router.GET("/v2/stats/"+platform+"/:tag/profile", injectPlatform(platform, profile))
router.GET("/v2/stats/"+platform+"/:tag/complete", injectPlatform(platform, stats))
router.GET("/v3/stats/"+platform+"/:tag/heroes/:heroes", injectPlatform(platform, heroes))
router.GET("/v3/stats/"+platform+"/:tag/profile", injectPlatform(platform, profile))
router.GET("/v3/stats/"+platform+"/:tag/complete", injectPlatform(platform, stats))
}
// Version
router.GET("/v2/version", versionHandler)
router.GET("/v3/version", versionHandler)
}
func loadHeroNames() {
@ -145,11 +159,30 @@ func loadHeroNames() {
}
}
var (
versionRegexp = regexp.MustCompile("^/(v\\d+)/")
)
func injectPlatform(platform string, handler httprouter.Handle) httprouter.Handle {
return func(w http.ResponseWriter, r *http.Request, ps httprouter.Params) {
ps = append(ps, httprouter.Param{Key: "platform", Value: platform})
handler(w, r, ps)
ctx := context.Background()
m := versionRegexp.FindStringSubmatch(r.RequestURI)
if m != nil {
version := VersionOne
switch m[1] {
case "v2":
version = VersionTwo
}
ctx = context.WithValue(ctx, "version", version)
}
handler(w, r.WithContext(ctx), ps)
}
}
@ -157,15 +190,21 @@ var (
tagRegexp = regexp.MustCompile("-(\\d+)$")
)
func statsResponse(w http.ResponseWriter, ps httprouter.Params, patch *jsonpatch.Patch) ([]byte, error) {
func statsResponse(w http.ResponseWriter, r *http.Request, ps httprouter.Params, patch *jsonpatch.Patch) ([]byte, error) {
var stats *ovrstat.PlayerStats
var err error
version := VersionOne
if v := r.Context().Value("version"); v != nil {
version = v.(ApiVersion)
}
tag := ps.ByName("tag")
tag = strings.Replace(tag, "#", "-", -1)
cacheKey := generateCacheKey(ps)
cacheKey := generateCacheKey(r, ps)
platform := ps.ByName("platform")
@ -262,11 +301,36 @@ func statsResponse(w http.ResponseWriter, ps httprouter.Params, patch *jsonpatch
iconUrl = rating.RankIcon
}
rating = int(totalRating / len(stats.Ratings))
rating = totalRating / len(stats.Ratings)
urlBase := iconUrl[0 : strings.Index(iconUrl, "rank-icons/")+11]
ratingIcon = urlBase + iconFor(rating)
if version == VersionThree {
m := make(map[string]ovrstat.Rating)
ratingsPatches := make([]patchOperation, len(stats.Ratings))
for i, rating := range stats.Ratings {
m[rating.Role] = rating
ratingsPatches[i] = patchOperation{
Op: OpRemove,
Path: "/ratings/" + rating.Role + "/role",
}
}
extra = append(extra, patchOperation{
Op: OpRemove,
Path: "/ratings",
}, patchOperation{
Op: OpAdd,
Path: "/ratings",
Value: m,
})
extra = append(extra, ratingsPatches...)
}
}
extra = append(extra, patchOperation{
@ -330,6 +394,16 @@ func iconFor(rating int) string {
return "rank-BronzeTier.png"
}
func generateCacheKey(ps httprouter.Params) string {
return ps.ByName("platform") + "-" + ps.ByName("tag")
func generateCacheKey(r *http.Request, ps httprouter.Params) string {
version := VersionOne
if v := r.Context().Value("version"); v != nil {
version = v.(ApiVersion)
}
return versionToString(version) + "-" + ps.ByName("platform") + "-" + ps.ByName("tag")
}
func versionToString(version ApiVersion) string {
return fmt.Sprintf("v%d", version)
}

View File

@ -1,5 +1,5 @@
fpm -s dir -t deb -p /build/$ARCH/owapi_${VERSION}_${ARCH}.deb \
-n ow-api -v $VERSION \
-n ow-api -v $VERSION -a $ARCH \
--deb-priority optional --force \
--deb-compression bzip2 \
--description "Overwatch API Server" \

View File

@ -1 +1,3 @@
curl -X POST "$UPLOAD_URL" -F "file_i386=@/build/i386/owapi_${VERSION}_i386.deb" -F "file_amd64=@/build/amd64/owapi_${VERSION}_amd64.deb" -F "file_armv7=@/build/armv7/owapi_${VERSION}_armv7.deb"
curl -X POST "$UPLOAD_URL" -F "file_i386=@/build/i386/owapi_${VERSION}_i386.deb" \
-F "file_amd64=@/build/amd64/owapi_${VERSION}_amd64.deb" \
-F "file_armv7=@/build/armv7/owapi_${VERSION}_armv7.deb"