Merge pull request #572 from textileio/sander/timeout-vm

db: ensure vm doesnt run forever
textileio · Jan 5, 2022 · 3be6a41 · 3be6a41
2 parents 0eb8098 + e24b357
commit 3be6a41
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/db/collection.go b/db/collection.go
@@ -43,6 +43,8 @@ var (
 	errCantCreateExistingInstance  = errors.New("can't create already existing instance")
 
 	baseKey = dsPrefix.ChildString("collection")
+
+	vmTimeout = time.Millisecond * 200
 )
 
 const (
@@ -85,6 +87,9 @@ func newCollection(d *DB, config CollectionConfig) (*Collection, error) {
 		return nil, err
 	}
 	vm := goja.New()
+	time.AfterFunc(vmTimeout, func() {
+		vm.Interrupt("validator timed out")
+	})
 	wv := []byte(config.WriteValidator)
 	rf := []byte(config.ReadFilter)
 	c := &Collection{