context_test.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. package context
  2. import (
  3. "io/ioutil"
  4. "os"
  5. "path/filepath"
  6. "testing"
  7. "time"
  8. "github.com/syndtr/goleveldb/leveldb"
  9. )
  10. func TestGetPut(t *testing.T) {
  11. tmp, err := ioutil.TempDir("", "")
  12. if err != nil {
  13. t.Fatal(err)
  14. }
  15. defer os.RemoveAll(tmp)
  16. ctx, err := Open(filepath.Join(tmp, "data"))
  17. if err != nil {
  18. t.Fatal(err)
  19. }
  20. defer ctx.Close()
  21. if _, err := ctx.Get("not_found"); err != leveldb.ErrNotFound {
  22. t.Fatalf("expected ErrNotFound, got \"%v\"", err)
  23. }
  24. a := &Route{
  25. URL: "http://www.kellegous.com/",
  26. Time: time.Now(),
  27. }
  28. if err := ctx.Put("key", a); err != nil {
  29. t.Fatal(err)
  30. }
  31. b, err := ctx.Get("key")
  32. if err != nil {
  33. t.Fatal(err)
  34. }
  35. if b.URL != a.URL {
  36. t.Fatalf("expected URL of %s, got %s", a.URL, b.URL)
  37. }
  38. if !b.Time.Equal(a.Time) {
  39. t.Fatalf("expected Time of %s, got %s", a.Time, b.Time)
  40. }
  41. }
  42. func TestNextID(t *testing.T) {
  43. tmp, err := ioutil.TempDir("", "")
  44. if err != nil {
  45. t.Fatal(err)
  46. }
  47. defer os.RemoveAll(tmp)
  48. ctx, err := Open(filepath.Join(tmp, "data"))
  49. if err != nil {
  50. t.Fatal(err)
  51. }
  52. defer ctx.Close()
  53. var e uint64 = 1
  54. for i := 0; i < 501; i++ {
  55. r, err := ctx.NextID()
  56. if err != nil {
  57. t.Fatal(err)
  58. }
  59. if r != e {
  60. t.Fatalf("expected %d, got %d", e, r)
  61. }
  62. e++
  63. }
  64. }