chore: add deps and rename project

Author: ogzhanolguncu

.github/workflows/release.yaml

@@ -0,0 +1,45 @@
+name: Release
+
+on:
+  release:
+    types:
+      - published
+
+jobs:
+  release:
+    name: Release
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Repo
+        uses: actions/checkout@v3
+
+      - name: Set env
+        run: echo "VERSION=${GITHUB_REF#refs/*/}" >> $GITHUB_ENV
+
+      - name: Setup Node
+        uses: actions/setup-node@v2
+        with:
+          node-version: 18
+
+      - name: Set package version
+        run: echo $(jq --arg v "${{ env.VERSION }}" '(.version) = $v' package.json) > package.json
+
+      - name: Install bun
+        run: npm install -g bun
+
+      - name: Install dependencies
+        run: bun install
+
+      - name: Build
+        run: bun run build
+
+      - name: Add npm token
+        run: echo "//registry.npmjs.org/:_authToken=${{secrets.NPM_TOKEN}}" > .npmrc
+
+      - name: Publish release candidate
+        if: "github.event.release.prerelease"
+        run: npm publish --access public --tag=canary --no-git-checks
+
+      - name: Publish
+        if: "!github.event.release.prerelease"
+        run: npm publish --access public --no-git-checks

.husky/commit-message

@@ -0,0 +1,4 @@
+#!/usr/bin/env sh
+. "$(dirname -- "$0")/_/husky.sh"
+
+bun --no -- commitlint --edit ""

.husky/pre-commit

@@ -1,4 +1,4 @@
 #!/usr/bin/env sh
 . "$(dirname -- "$0")/_/husky.sh"
 
-bun run fmt && bun run test
+bun run fmt && bun run test

.husky/pre-push

@@ -0,0 +1,4 @@
+#!/usr/bin/env sh
+. "$(dirname -- "$0")/_/husky.sh"
+
+bun run build

.vscode/extensions.json

@@ -0,0 +1,3 @@
+{
+  "recommendations": ["biomejs.biome"]
+}

.vscode/settings.json

@@ -0,0 +1,23 @@
+{
+  "editor.formatOnSave": true,
+  "git.autofetch": true,
+  "editor.codeActionsOnSave": {
+    "source.fixAll": "explicit"
+  },
+  "[html]": {
+    "editor.defaultFormatter": "biomejs.biome"
+  },
+  "[json]": {
+    "editor.defaultFormatter": "biomejs.biome"
+  },
+  "[javascript]": {
+    "editor.defaultFormatter": "biomejs.biome"
+  },
+  "[jsonc]": {
+    "editor.defaultFormatter": "biomejs.biome"
+  },
+  "[typescript]": {
+    "editor.defaultFormatter": "biomejs.biome"
+  },
+  "editor.defaultFormatter": "biomejs.biome"
+}

README.md

@@ -1,4 +1,4 @@
-# Upstash SQS · ![license](https://img.shields.io/npm/l/%40upstash%2Fsqs) [![Tests](https://github.com/upstash/sqs/actions/workflows/tests.yaml/badge.svg)](https://github.com/upstash/sqs/actions/workflows/tests.yaml) ![npm (scoped)](https://img.shields.io/npm/v/@upstash/sqs) ![npm bundle size](https://img.shields.io/bundlephobia/minzip/@upstash/sqs) ![npm weekly download](https://img.shields.io/npm/dw/%40upstash%2Fsqs)
+# Upstash Queue · ![license](https://img.shields.io/npm/l/%40upstash%2Fqueue) [![Tests](https://github.com/upstash/queue/actions/workflows/tests.yaml/badge.svg)](https://github.com/upstash/queue/actions/workflows/tests.yaml) ![npm (scoped)](https://img.shields.io/npm/v/@upstash/queue) ![npm bundle size](https://img.shields.io/bundlephobia/minzip/@upstash/queue) ![npm weekly download](https://img.shields.io/npm/dw/%40upstash%2Fqueue)
 
 > [!NOTE]> **This project is in the Experimental Stage.**
 >
@@ -13,7 +13,7 @@ A simple, fast, robust stream based message queue for Node.js, backed by Upstash
 
 ```ts
 import { Redis } from "@upstash/redis";
-import { Queue } from "@upstash/sqs";
+import { Queue } from "@upstash/queue";
 
 const queue = new Queue({ redis: new Redis() });
 
@@ -25,11 +25,11 @@ expect(message1?.body).toEqual({ hello: "world1" });
 
 ## Introduction
 
-`@upstash/sqs` is a Node.js library that provides a simple and efficient way to implement a message queue system using Redis streams. It offers features such as message sending, receiving, automatic message verification, and concurrency control. This library is particularly useful for building distributed systems and background job processing.
+`@upstash/queue` is a Node.js library that provides a simple and efficient way to implement a message queue system using Redis streams. It offers features such as message sending, receiving, automatic message verification, and concurrency control. This library is particularly useful for building distributed systems and background job processing.
 
-## Why Upstash SQS?
+## Why Upstash Queue?
 
-Upstash SQS brings the simplicity and performance of Redis streams to Node.js developers, making it easy to integrate a robust message queue system into their applications. Whether you're working on distributed systems, background job processing, or other asynchronous workflows, Upstash SQS provides essential features such as message sending, receiving, automatic verification, and concurrency control.
+Upstash queue brings the simplicity and performance of Redis streams to Node.js developers, making it easy to integrate a robust message queue system into their applications. Whether you're working on distributed systems, background job processing, or other asynchronous workflows, Upstash queue provides essential features such as message sending, receiving, automatic verification, and concurrency control.
 
 **Key Features:**
 
@@ -54,17 +54,17 @@ Upstash SQS brings the simplicity and performance of Redis streams to Node.js de
 
 ## Installation
 
-To start using Upstash SQS, install the library via npm:
+To start using Upstash queue, install the library via npm:
 
 ```sh
-npm install @upstash/sqs
+npm install @upstash/queue
 ```
 
 ## Getting Started
 
 ```typescript
 import Redis from "@upstash/redis";
-import { Queue } from "@upstash/sqs";
+import { Queue } from "@upstash/queue";
 
 const redis = new Redis();
 const queue = new Queue({ redis });

biome.json

@@ -4,6 +4,9 @@
   "linter": {
     "enabled": true,
     "rules": {
+      "nursery": {
+        "useAwait": "error"
+      },
       "recommended": true,
       "a11y": {
         "noSvgWithoutTitle": "off"

bun.lockb

@@ -0,0 +1,50 @@
+// build: Changes that affect the build system or external dependencies (example scopes: gulp, broccoli, npm)
+// ci: Changes to our CI configuration files and scripts (example scopes: Travis, Circle, BrowserStack, SauceLabs)
+// docs: Documentation only changes
+// feat: A new feature
+// fix: A bug fix
+// perf: A code change that improves performance
+// refactor: A code change that neither fixes a bug nor adds a feature
+// style: Changes that do not affect the meaning of the code (white-space, formatting, missing semi-colons, etc)
+// test: Adding missing tests or correcting existing tests
+
+module.exports = {
+  extends: ["@commitlint/config-conventional"],
+  rules: {
+    "body-leading-blank": [1, "always"],
+    "body-max-line-length": [2, "always", 100],
+    "footer-leading-blank": [1, "always"],
+    "footer-max-line-length": [2, "always", 100],
+    "header-max-length": [2, "always", 100],
+    "scope-case": [2, "always", "lower-case"],
+    "subject-case": [
+      2,
+      "never",
+      ["sentence-case", "start-case", "pascal-case", "upper-case"],
+    ],
+    "subject-empty": [2, "never"],
+    "subject-full-stop": [2, "never", "."],
+    "type-case": [2, "always", "lower-case"],
+    "type-empty": [2, "never"],
+    "type-enum": [
+      2,
+      "always",
+      [
+        "build",
+        "chore",
+        "ci",
+        "docs",
+        "feat",
+        "fix",
+        "perf",
+        "refactor",
+        "revert",
+        "style",
+        "test",
+        "translation",
+        "security",
+        "changeset",
+      ],
+    ],
+  },
+};

commitlint.config.js

@@ -1,10 +1,8 @@
 "use client";
-import React, { useState, useEffect } from "react";
+import { useState } from "react";
 
-import { Queue } from "./../../../src";
+import { CSSTransition, TransitionGroup } from "react-transition-group";
 import * as uuid from "uuid";
-import { Redis } from "@upstash/redis";
-import { TransitionGroup, CSSTransition } from "react-transition-group";
 
 type MessageBody = {
   content: string;
@@ -15,7 +13,7 @@ type MessageWithId = {
   body: MessageBody;
 };
 
-const queueName = `sqs-${uuid.v4().substring(0, 18)}`;
+const queueName = `queue-${uuid.v4().substring(0, 18)}`;
 
 export default function Home() {
   const [messageInput, setMessageInput] = useState<string>(
@@ -57,12 +55,12 @@ export default function Home() {
     <main>
       <header>
         <h1 className="text-4xl font-bold">
-          Welcome to <span className="text-primary-500">@upstash/sqs</span>
+          Welcome to <span className="text-primary-500">@upstash/queue</span>
         </h1>
 
         <p className="mt-4">
-          This is an example of how to use @upstash/sqs as a FIFO queue in your
-          Next.js application.
+          This is an example of how to use @upstash/queue as a FIFO queue in
+          your Next.js application.
         </p>
 
         <p className="mt-4">

examples/nextjs14/app/page.tsx

@@ -1,10 +1,10 @@
 {
-  "name": "@upstash/sqs",
+  "name": "@upstash/queue",
   "description": "A message queue based on Redis streams, without dependencies.",
   "module": "./dist/index.mjs",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
-  "version": "1.0.1",
+  "version": "1.0.0",
   "keywords": [
     "redis",
     "stream",
@@ -15,14 +15,14 @@
   "author": "Oguzhan Olguncu <[email protected]>",
   "repository": {
     "type": "git",
-    "url": "https://github.com/upstash/sqs"
+    "url": "https://github.com/upstash/queue"
   },
   "license": "MIT",
   "files": [
     "dist"
   ],
   "bugs": {
-    "url": "https://github.com/upstash/sqs/issues"
+    "url": "https://github.com/upstash/queue/issues"
   },
   "scripts": {
     "test": "bun test src --coverage --bail",
@@ -31,15 +31,17 @@
     "prepare": "husky install"
   },
   "dependencies": {
-    "@types/uuid": "^9.0.8",
     "@upstash/redis": "1.28.0",
     "uuid": "^9.0.1"
   },
   "devDependencies": {
-    "typescript": "^5.0.0",
-    "@biomejs/biome": "^1.4.1",
+    "@types/uuid": "^9.0.8",
+    "typescript": "latest",
+    "@biomejs/biome": "^1.5.3",
     "bun-types": "latest",
-    "husky": "^8.0.3",
-    "tsup": "latest"
+    "husky": "^9.0.11",
+    "tsup": "latest",
+    "@commitlint/cli": "^18.6.0",
+    "@commitlint/config-conventional": "^18.6.0"
   }
 }

package.json

@@ -308,7 +308,7 @@ describe("Queue", () => {
 
     test(
       "should poll until data arives",
-      async () => {
+      () => {
         const throwable = async () => {
           const fakeValue = randomValue();
           const producer = new Queue({ redis, queueName: "app-logs" });

src/queue.test.ts

@@ -253,7 +253,7 @@ export class Queue {
     invariant(consumerGroupName, "Consumer group name cannot be empty when receiving a message");
     invariant(queueName, "Queue name cannot be empty when receving a message");
 
-    return redis.xreadgroup(consumerGroupName, consumerName, queueName, ">", {
+    return await redis.xreadgroup(consumerGroupName, consumerName, queueName, ">", {
       count: 1,
       blockMS: blockTimeMs,
     });

src/queue.ts

@@ -2,7 +2,7 @@ import { describe, expect, test } from "bun:test";
 import { parseXclaimAutoResponse, parseXreadGroupResponse } from "./utils";
 
 describe("Response Parsers", () => {
-  test("should parse XCLAIMAUTO response", async () => {
+  test("should parse XCLAIMAUTO response", () => {
     const input = ["0-0", [["1703754659687-0", ["messageBody", '{"hello":"world"}']]], []];
 
     expect(parseXclaimAutoResponse(input)).toEqual({
@@ -11,7 +11,7 @@ describe("Response Parsers", () => {
     });
   });
 
-  test("should parse XREADGROUP response", async () => {
+  test("should parse XREADGROUP response", () => {
     const input = [
       ["UpstashMQ:1251e0e7", [["1703755686316-0", ["messageBody", '{"hello":"world"}']]]],
     ];