Skip to content

Commit

Permalink
chore: format some files
Browse files Browse the repository at this point in the history
  • Loading branch information
@inaiat
inaiat committed Nov 25, 2024
1 parent bb776e9 commit fb3a44c
Show file tree
Hide file tree
Showing 6 changed files with 41 additions and 41 deletions.
2 changes: 0 additions & 2 deletions example/kafka-stream-reconnect.mjs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -94,6 +94,4 @@ async function startConsumer() {
await setupConsumerWithRetry()
}


await startConsumer()

6 changes: 3 additions & 3 deletions js-binding.d.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ export interface RetryStrategy {
}
export enum CommitMode {
Sync = 0,
Async = 1
Async = 1,
}
export interface ConsumerConfiguration {
groupId: string
Expand All @@ -25,7 +25,7 @@ export interface ConsumerConfiguration {
export enum PartitionPosition {
Beginning = 'Beginning',
End = 'End',
Stored = 'Stored'
Stored = 'Stored',
}
export interface OffsetModel {
offset?: number
Expand All @@ -44,7 +44,7 @@ export enum SecurityProtocol {
Plaintext = 'Plaintext',
Ssl = 'Ssl',
SaslPlaintext = 'SaslPlaintext',
SaslSsl = 'SaslSsl'
SaslSsl = 'SaslSsl',
}
export interface KafkaConfiguration {
brokers: string
Expand Down
29 changes: 15 additions & 14 deletions js-binding.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ switch (platform) {
switch (arch) {
case 'x64':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.win32-x64-msvc.node')
join(__dirname, 'kafka-crab-js.win32-x64-msvc.node'),
)
try {
if (localFileExisted) {
Expand All @@ -77,7 +77,7 @@ switch (platform) {
break
case 'ia32':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node')
join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node'),
)
try {
if (localFileExisted) {
Expand All @@ -91,7 +91,7 @@ switch (platform) {
break
case 'arm64':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node')
join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node'),
)
try {
if (localFileExisted) {
Expand Down Expand Up @@ -132,7 +132,7 @@ switch (platform) {
break
case 'arm64':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.darwin-arm64.node')
join(__dirname, 'kafka-crab-js.darwin-arm64.node'),
)
try {
if (localFileExisted) {
Expand Down Expand Up @@ -168,7 +168,7 @@ switch (platform) {
case 'x64':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-x64-musl.node')
join(__dirname, 'kafka-crab-js.linux-x64-musl.node'),
)
try {
if (localFileExisted) {
Expand All @@ -181,7 +181,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-x64-gnu.node')
join(__dirname, 'kafka-crab-js.linux-x64-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -197,7 +197,7 @@ switch (platform) {
case 'arm64':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm64-musl.node')
join(__dirname, 'kafka-crab-js.linux-arm64-musl.node'),
)
try {
if (localFileExisted) {
Expand All @@ -210,7 +210,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node')
join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -226,7 +226,7 @@ switch (platform) {
case 'arm':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node')
join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node'),
)
try {
if (localFileExisted) {
Expand All @@ -239,7 +239,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node')
join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node'),
)
try {
if (localFileExisted) {
Expand All @@ -255,7 +255,7 @@ switch (platform) {
case 'riscv64':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node')
join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node'),
)
try {
if (localFileExisted) {
Expand All @@ -268,7 +268,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node')
join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -283,7 +283,7 @@ switch (platform) {
break
case 's390x':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node')
join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -310,7 +310,8 @@ if (!nativeBinding) {
throw new Error(`Failed to load native binding`)
}

const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } = nativeBinding
const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } =
nativeBinding

module.exports.KafkaConsumer = KafkaConsumer
module.exports.CommitMode = CommitMode
Expand Down
6 changes: 3 additions & 3 deletions js-src/js-binding.d.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ export interface RetryStrategy {
}
export enum CommitMode {
Sync = 0,
Async = 1
Async = 1,
}
export interface ConsumerConfiguration {
groupId: string
Expand All @@ -25,7 +25,7 @@ export interface ConsumerConfiguration {
export enum PartitionPosition {
Beginning = 'Beginning',
End = 'End',
Stored = 'Stored'
Stored = 'Stored',
}
export interface OffsetModel {
offset?: number
Expand All @@ -44,7 +44,7 @@ export enum SecurityProtocol {
Plaintext = 'Plaintext',
Ssl = 'Ssl',
SaslPlaintext = 'SaslPlaintext',
SaslSsl = 'SaslSsl'
SaslSsl = 'SaslSsl',
}
export interface KafkaConfiguration {
brokers: string
Expand Down
29 changes: 15 additions & 14 deletions js-src/js-binding.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ switch (platform) {
switch (arch) {
case 'x64':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.win32-x64-msvc.node')
join(__dirname, 'kafka-crab-js.win32-x64-msvc.node'),
)
try {
if (localFileExisted) {
Expand All @@ -77,7 +77,7 @@ switch (platform) {
break
case 'ia32':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node')
join(__dirname, 'kafka-crab-js.win32-ia32-msvc.node'),
)
try {
if (localFileExisted) {
Expand All @@ -91,7 +91,7 @@ switch (platform) {
break
case 'arm64':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node')
join(__dirname, 'kafka-crab-js.win32-arm64-msvc.node'),
)
try {
if (localFileExisted) {
Expand Down Expand Up @@ -132,7 +132,7 @@ switch (platform) {
break
case 'arm64':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.darwin-arm64.node')
join(__dirname, 'kafka-crab-js.darwin-arm64.node'),
)
try {
if (localFileExisted) {
Expand Down Expand Up @@ -168,7 +168,7 @@ switch (platform) {
case 'x64':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-x64-musl.node')
join(__dirname, 'kafka-crab-js.linux-x64-musl.node'),
)
try {
if (localFileExisted) {
Expand All @@ -181,7 +181,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-x64-gnu.node')
join(__dirname, 'kafka-crab-js.linux-x64-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -197,7 +197,7 @@ switch (platform) {
case 'arm64':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm64-musl.node')
join(__dirname, 'kafka-crab-js.linux-arm64-musl.node'),
)
try {
if (localFileExisted) {
Expand All @@ -210,7 +210,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node')
join(__dirname, 'kafka-crab-js.linux-arm64-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -226,7 +226,7 @@ switch (platform) {
case 'arm':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node')
join(__dirname, 'kafka-crab-js.linux-arm-musleabihf.node'),
)
try {
if (localFileExisted) {
Expand All @@ -239,7 +239,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node')
join(__dirname, 'kafka-crab-js.linux-arm-gnueabihf.node'),
)
try {
if (localFileExisted) {
Expand All @@ -255,7 +255,7 @@ switch (platform) {
case 'riscv64':
if (isMusl()) {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node')
join(__dirname, 'kafka-crab-js.linux-riscv64-musl.node'),
)
try {
if (localFileExisted) {
Expand All @@ -268,7 +268,7 @@ switch (platform) {
}
} else {
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node')
join(__dirname, 'kafka-crab-js.linux-riscv64-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -283,7 +283,7 @@ switch (platform) {
break
case 's390x':
localFileExisted = existsSync(
join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node')
join(__dirname, 'kafka-crab-js.linux-s390x-gnu.node'),
)
try {
if (localFileExisted) {
Expand All @@ -310,7 +310,8 @@ if (!nativeBinding) {
throw new Error(`Failed to load native binding`)
}

const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } = nativeBinding
const { KafkaConsumer, CommitMode, PartitionPosition, SecurityProtocol, KafkaClientConfig, KafkaProducer } =
nativeBinding

module.exports.KafkaConsumer = KafkaConsumer
module.exports.CommitMode = CommitMode
Expand Down
10 changes: 5 additions & 5 deletions tsconfig.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,14 +9,14 @@
"allowJs": true,
"skipLibCheck": true,
"rootDir": "./js-src",
"outDir": "./dist",
"outDir": "./dist"
},
"include": [
"**/*.ts",
"**/*.ts"
],
"copyFiles": [
"js_src/js-binding.d.ts",
"js_src/js-binding.js",
"js_src/js-binding.js"
],
"exclude": [
"__test__",
Expand All @@ -27,5 +27,5 @@
"npm",
"js-binding.js",
"js-binding.d.ts"
],
}
]
}

0 comments on commit fb3a44c

Please sign in to comment.