--- 
+++ 
@@ -2,9 +2,29 @@
     // Load given options to the object
     this.options = options
 
-    // Construct Grafana Loki push API url
+    if (!options.host) {
+      throw new Error('Host parameter is required')
+    }
+
+    // Validate and construct Grafana Loki push API url
     const URL = this.loadUrl()
-    this.url = new URL(this.options.host + '/loki/api/v1/push')
+    try {
+      // Check if host is already a full URL
+      const hostUrl = new URL(options.host)
+      // If host contains path, warn user and strip it
+      if (hostUrl.pathname !== '/') {
+        console.warn('Host parameter should only contain the base URL. Path will be ignored.')
+        hostUrl.pathname = '/'
+      }
+      this.url = new URL('/loki/api/v1/push', hostUrl.toString())
+    } catch (err) {
+      // If host is not a valid URL, try prepending http://
+      try {
+        this.url = new URL('/loki/api/v1/push', 'http://' + options.host)
+      } catch (err) {
+        throw new Error('Invalid host parameter: ' + options.host)
+      }
+    }
 
     const btoa = require('btoa')
     // Parse basic auth parameters if given

--- 
+++ 
@@ -1,6 +1,16 @@
         // Send the data to Grafana Loki
         req.post(this.url, this.contentType, this.options.headers, reqBody, this.options.timeout, this.options.httpAgent, this.options.httpsAgent)
-          .then(() => {
+          .then((response) => {
+            // Validate response
+            if (typeof response === 'string') {
+              if (response.includes('404')) {
+                throw new Error('Loki API endpoint not found: ' + response)
+              }
+              if (response.includes('error')) {
+                throw new Error('Loki API error: ' + response)
+              }
+            }
+            
             // No need to clear the batch if batching is disabled
             logEntry === undefined && this.clearBatch()
             this.batchSent()
@@ -10,8 +20,14 @@
             // Clear the batch on error if enabled
             this.options.clearOnError && this.clearBatch()
 
-            this.options.onConnectionError !== undefined && this.options.onConnectionError(err)
+            // Enhanced error handling
+            const error = new Error(
+              `Failed to send logs to Loki: ${err.message || err}`
+            )
+            error.originalError = err
+
+            this.options.onConnectionError !== undefined && this.options.onConnectionError(error)
 
             this.batchSent()
-            reject(err)
+            reject(error)
           })

--- 
+++ 
@@ -13,3 +13,50 @@
       expect(error).toBeTruthy()
     }
   })
+
+  describe('URL validation tests', () => {
+    it('Should throw error when host is missing', () => {
+      const options = JSON.parse(JSON.stringify(fixtures.options_json))
+      delete options.host
+      expect(() => new Batcher(options)).toThrow('Host parameter is required')
+    })
+
+    it('Should handle full URL in host parameter', () => {
+      const options = JSON.parse(JSON.stringify(fixtures.options_json))
+      options.host = 'http://localhost:3100/some/path'
+      const batcher = new Batcher(options)
+      expect(batcher.url.toString()).toBe('http://localhost:3100/loki/api/v1/push')
+    })
+
+    it('Should handle invalid URLs', () => {
+      const options = JSON.parse(JSON.stringify(fixtures.options_json))
+      options.host = ':::invalid:::'
+      expect(() => new Batcher(options)).toThrow('Invalid host parameter')
+    })
+  })
+
+  describe('Error handling tests', () => {
+    it('Should handle 404 responses', async () => {
+      const responseText = '404 Not Found'
+      req.post.mockResolvedValue(responseText)
+      
+      try {
+        await batcher.sendBatchToLoki()
+        fail('Should have thrown error')
+      } catch (err) {
+        expect(err.message).toContain('Loki API endpoint not found')
+      }
+    })
+
+    it('Should handle API errors', async () => {
+      const responseText = 'error: invalid request'
+      req.post.mockResolvedValue(responseText)
+      
+      try {
+        await batcher.sendBatchToLoki()
+        fail('Should have thrown error')
+      } catch (err) {
+        expect(err.message).toContain('Loki API error')
+      }
+    })
+  })

--- 
+++ 
@@ -2,10 +2,16 @@
     const req = lib.request(options, res => {
       let resData = ''
       res.on('data', _data => (resData += _data))
-      res.on('end', () => resolve(resData))
+      res.on('end', () => {
+        if (res.statusCode >= 400) {
+          reject(new Error(`HTTP ${res.statusCode}: ${resData}`))
+        } else {
+          resolve(resData)
+        }
+      })
     })
 
     // Error listener
     req.on('error', error => {
-      reject(error)
+      reject(new Error(`Request failed: ${error.message}`))
     })