[API-05] Territories API (CRUD for territories, assignment) (retry 1)

{
  "cost": {
    "input_tokens": 28,
    "estimated_usd": 0.102174,
    "output_tokens": 6806
  },
  "model": "claude-sonnet-4-20250514",
  "status": "success",
  "transport": "anthropic_api",
  "latency_ms": 67275,
  "response_text": "I'll create a comprehensive Territories API with CRUD operations and assignment functionality.\n\n```typescript\n// types/territory.ts\nexport interface Territory {\n  id: string;\n  name: string;\n  description?: string;\n  boundaries: GeoJSON.Polygon;\n  assignedTo?: string; // User ID\n  status: 'active' | 'inactive' | 'pending';\n  priority: 'low' | 'medium' | 'high';\n  properties: {\n    population?: number;\n    area?: number; // in square kilometers\n    difficulty?: 'easy' | 'medium' | 'hard';\n    lastWorked?: Date;\n    completionRate?: number;\n  };\n  metadata: {\n    createdAt: Date;\n    updatedAt: Date;\n    createdBy: string;\n    version: number;\n  };\n}\n\nexport interface TerritoryAssignment {\n  id: string;\n  territoryId: string;\n  assignedTo: string;\n  assignedBy: string;\n  assignedAt: Date;\n  expectedCompletion?: Date;\n  status: 'assigned' | 'in_progress' | 'completed' | 'reassigned';\n  notes?: string;\n}\n\nexport interface CreateTerritoryRequest {\n  name: string;\n  description?: string;\n  boundaries: GeoJSON.Polygon;\n  priority?: 'low' | 'medium' | 'high';\n  properties?: Partial<Territory['properties']>;\n}\n\nexport interface UpdateTerritoryRequest {\n  name?: string;\n  description?: string;\n  boundaries?: GeoJSON.Polygon;\n  status?: Territory['status'];\n  priority?: Territory['priority'];\n  properties?: Partial<Territory['properties']>;\n}\n\nexport interface AssignTerritoryRequest {\n  assignedTo: string;\n  expectedCompletion?: Date;\n  notes?: string;\n}\n\nexport interface TerritoryQuery {\n  status?: Territory['status'];\n  priority?: Territory['priority'];\n  assignedTo?: string;\n  unassigned?: boolean;\n  search?: string;\n  bounds?: {\n    north: number;\n    south: number;\n    east: number;\n    west: number;\n  };\n  page?: number;\n  limit?: number;\n  sortBy?: 'name' | 'priority' | 'lastWorked' | 'createdAt';\n  sortOrder?: 'asc' | 'desc';\n}\n```\n\n```typescript\n// lib/territory-service.ts\nimport { Territory, TerritoryAssignment, TerritoryQuery } from '@/types/territory';\nimport * as turf from '@turf/turf';\n\nexport class TerritoryService {\n  private baseUrl: string;\n\n  constructor(baseUrl: string) {\n    this.baseUrl = baseUrl;\n  }\n\n  // CRUD Operations\n  async createTerritory(territory: CreateTerritoryRequest): Promise<Territory> {\n    // Validate boundaries\n    this.validateBoundaries(territory.boundaries);\n    \n    // Calculate area automatically\n    const area = turf.area(territory.boundaries) / 1000000; // Convert to km²\n    \n    const response = await fetch(`${this.baseUrl}/territories`, {\n      method: 'POST',\n      headers: { 'Content-Type': 'application/json' },\n      body: JSON.stringify({\n        ...territory,\n        properties: {\n          ...territory.properties,\n          area\n        }\n      })\n    });\n\n    if (!response.ok) {\n      throw new Error(`Failed to create territory: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async getTerritories(query: TerritoryQuery = {}): Promise<{\n    territories: Territory[];\n    total: number;\n    page: number;\n    totalPages: number;\n  }> {\n    const searchParams = new URLSearchParams();\n    \n    Object.entries(query).forEach(([key, value]) => {\n      if (value !== undefined) {\n        if (key === 'bounds') {\n          searchParams.append(key, JSON.stringify(value));\n        } else {\n          searchParams.append(key, String(value));\n        }\n      }\n    });\n\n    const response = await fetch(`${this.baseUrl}/territories?${searchParams}`);\n    \n    if (!response.ok) {\n      throw new Error(`Failed to fetch territories: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async getTerritory(id: string): Promise<Territory> {\n    const response = await fetch(`${this.baseUrl}/territories/${id}`);\n    \n    if (!response.ok) {\n      if (response.status === 404) {\n        throw new Error('Territory not found');\n      }\n      throw new Error(`Failed to fetch territory: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async updateTerritory(id: string, updates: UpdateTerritoryRequest): Promise<Territory> {\n    if (updates.boundaries) {\n      this.validateBoundaries(updates.boundaries);\n      \n      // Recalculate area if boundaries changed\n      const area = turf.area(updates.boundaries) / 1000000;\n      updates.properties = {\n        ...updates.properties,\n        area\n      };\n    }\n\n    const response = await fetch(`${this.baseUrl}/territories/${id}`, {\n      method: 'PUT',\n      headers: { 'Content-Type': 'application/json' },\n      body: JSON.stringify(updates)\n    });\n\n    if (!response.ok) {\n      throw new Error(`Failed to update territory: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async deleteTerritory(id: string): Promise<void> {\n    const response = await fetch(`${this.baseUrl}/territories/${id}`, {\n      method: 'DELETE'\n    });\n\n    if (!response.ok) {\n      throw new Error(`Failed to delete territory: ${response.statusText}`);\n    }\n  }\n\n  // Assignment Operations\n  async assignTerritory(\n    territoryId: string, \n    assignment: AssignTerritoryRequest\n  ): Promise<TerritoryAssignment> {\n    const response = await fetch(`${this.baseUrl}/territories/${territoryId}/assign`, {\n      method: 'POST',\n      headers: { 'Content-Type': 'application/json' },\n      body: JSON.stringify(assignment)\n    });\n\n    if (!response.ok) {\n      throw new Error(`Failed to assign territory: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async unassignTerritory(territoryId: string): Promise<void> {\n    const response = await fetch(`${this.baseUrl}/territories/${territoryId}/unassign`, {\n      method: 'POST'\n    });\n\n    if (!response.ok) {\n      throw new Error(`Failed to unassign territory: ${response.statusText}`);\n    }\n  }\n\n  async getTerritoryAssignments(territoryId: string): Promise<TerritoryAssignment[]> {\n    const response = await fetch(`${this.baseUrl}/territories/${territoryId}/assignments`);\n    \n    if (!response.ok) {\n      throw new Error(`Failed to fetch assignments: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async getUserTerritories(userId: string): Promise<Territory[]> {\n    const response = await fetch(`${this.baseUrl}/users/${userId}/territories`);\n    \n    if (!response.ok) {\n      throw new Error(`Failed to fetch user territories: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  // Utility Methods\n  async getTerritoriesInBounds(bounds: {\n    north: number;\n    south: number;\n    east: number;\n    west: number;\n  }): Promise<Territory[]> {\n    return this.getTerritories({ bounds }).then(result => result.territories);\n  }\n\n  async findOverlappingTerritories(boundaries: GeoJSON.Polygon): Promise<Territory[]> {\n    const response = await fetch(`${this.baseUrl}/territories/overlaps`, {\n      method: 'POST',\n      headers: { 'Content-Type': 'application/json' },\n      body: JSON.stringify({ boundaries })\n    });\n\n    if (!response.ok) {\n      throw new Error(`Failed to find overlapping territories: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  async getTerritoryStatistics(): Promise<{\n    total: number;\n    assigned: number;\n    unassigned: number;\n    completed: number;\n    byPriority: Record<Territory['priority'], number>;\n    byStatus: Record<Territory['status'], number>;\n  }> {\n    const response = await fetch(`${this.baseUrl}/territories/statistics`);\n    \n    if (!response.ok) {\n      throw new Error(`Failed to fetch statistics: ${response.statusText}`);\n    }\n\n    return response.json();\n  }\n\n  private validateBoundaries(boundaries: GeoJSON.Polygon): void {\n    try {\n      const feature = turf.polygon(boundaries.coordinates);\n      \n      // Check if polygon is valid\n      const bbox = turf.bbox(feature);\n      if (!bbox || bbox.some(coord => !isFinite(coord))) {\n        throw new Error('Invalid polygon coordinates');\n      }\n\n      // Check for self-intersections\n      const kinks = turf.kinks(feature);\n      if (kinks.features.length > 0) {\n        throw new Error('Polygon has self-intersections');\n      }\n\n    } catch (error) {\n      throw new Error(`Invalid territory boundaries: ${error.message}`);\n    }\n  }\n}\n```\n\n```typescript\n// pages/api/territories/index.ts\nimport { NextApiRequest, NextApiResponse } from 'next';\nimport { Territory, CreateTerritoryRequest, TerritoryQuery } from '@/types/territory';\nimport { withAuth } from '@/middleware/auth';\nimport { validateTerritoryData } from '@/lib/validation';\nimport { TerritoryRepository } from '@/lib/repositories/territory-repository';\n\nasync function handler(req: NextApiRequest, res: NextApiResponse) {\n  const territoryRepo = new TerritoryRepository();\n\n  switch (req.method) {\n    case 'GET':\n      return handleGetTerritories(req, res, territoryRepo);\n    case 'POST':\n      return handleCreateTerritory(req, res, territoryRepo);\n    default:\n      return res.status(405).json({ error: 'Method not allowed' });\n  }\n}\n\nasync function handleGetTerritories(\n  req: NextApiRequest,\n  res: NextApiResponse,\n  repo: TerritoryRepository\n) {\n  try {\n    const query: TerritoryQuery = {\n      status: req.query.status as Territory['status'],\n      priority: req.query.priority as Territory['priority'],\n      assignedTo: req.query.assignedTo as string,\n      unassigned: req.query.unassigned === 'true',\n      search: req.query.search as string,\n      bounds: req.query.bounds ? JSON.parse(req.query.bounds as string) : undefined,\n      page: req.query.page ? parseInt(req.query.page as string) : 1,\n      limit: req.query.limit ? parseInt(req.query.limit as string) : 20,\n      sortBy: req.query.sortBy as TerritoryQuery['sortBy'] || 'name',\n      sortOrder: req.query.sortOrder as 'asc' | 'desc' || 'asc'\n    };\n\n    const result = await repo.findMany(query);\n    res.status(200).json(result);\n  } catch (error) {\n    console.error('Error fetching territories:', error);\n    res.status(500).json({ error: 'Failed to fetch territories' });\n  }\n}\n\nasync function handleCreateTerritory(\n  req: NextApiRequest,\n  res: NextApiResponse,\n  repo: TerritoryRepository\n) {\n  try {\n    const territoryData: CreateTerritoryRequest = req.body;\n    const userId = req.user?.id;\n\n    // Validate input\n    const validation = validateTerritoryData(territoryData);\n    if (!validation.isValid) {\n      return res.status(400).json({ error: validation.errors });\n    }\n\n    // Check for overlapping territories\n    const overlapping = await repo.findOverlapping(territoryData.boundaries);\n    if (overlapping.length > 0) {\n      return res.status(409).json({ \n        error: 'Territory overlaps with existing territories',\n        overlapping: overlapping.map(t => ({ id: t.id, name: t.name }))\n      });\n    }\n\n    const territory = await repo.create({\n      ...territoryData,\n      status: 'active',\n      assignedTo: undefined,\n      metadata: {\n        createdAt: new Date(),\n        updatedAt: new Date(),\n        createdBy: userId,\n        version: 1\n      }\n    });\n\n    res.status(201).json(territory);\n  } catch (error) {\n    console.error('Error creating territory:', error);\n    res.status(500).json({ error: 'Failed to create territory' });\n  }\n}\n\nexport default withAuth(handler);\n```\n\n```typescript\n// pages/api/territories/[id].ts\nimport { NextApiRequest, NextApiResponse } from 'next';\nimport { UpdateTerritoryRequest } from '@/types/territory';\nimport { withAuth } from '@/middleware/auth';\nimport { TerritoryRepository } from '@/lib/repositories/territory-repository';\n\nasync function handler(req: NextApiRequest, res: NextApiResponse) {\n  const { id } = req.query;\n  const territoryRepo = new TerritoryRepository();\n\n  if (typeof id !== 'string') {\n    return res.status(400).json({ error: 'Invalid territory ID' });\n  }\n\n  switch (req.method) {\n    case 'GET':\n      return handleGetTerritory(req, res, territoryRepo, id);\n    case 'PUT':\n      return handleUpdateTerritory(req, res, territoryRepo, id);\n    case 'DELETE':\n      return handleDeleteTerritory(req, res, territoryRepo, id);\n    default:\n      return res.status(405).json({ error: 'Method not allowed' });\n  }\n}\n\nasync function handleGetTerritory(\n  req: NextApiRequest,\n  res: NextApiResponse,\n  repo: TerritoryRepository,\n  id: string\n) {\n  try {\n    const territory = await repo.findById(id);\n    \n    if (!territory) {\n      return res.status(404).json({ error: 'Territory not found' });\n    }\n\n    res.status(200).json(territory);\n  } catch (error) {\n    console.error('Error fetching territory:', error);\n    res.status(500).json({ error: 'Failed to fetch territory' });\n  }\n}\n\nasync function handleUpdateTerritory(\n  req: NextApiRequest,\n  res: NextApiResponse,\n  repo: TerritoryRepository,\n  id: string\n) {\n  try {\n    const updates: UpdateTerritoryRequest = req.body;\n    const userId = req.user?.id;\n\n    const existing = await repo.findById(id);\n    if (!existing) {\n      return res.status(404).json({ error: 'Territory not found' });\n    }\n\n    // Check for overlaps if boundaries are being updated\n    if (updates.boundaries) {\n      const overlapping = await repo.findOverlapping(updates.boundaries, id);\n      if (overlapping.length > 0) {\n        return res.status(409).json({ \n          error: 'Updated territory would overlap with existing territories',\n          overlapping: overlapping.map(t => ({ id: t.id, name: t.name }))\n        });\n      }\n    }\n\n    const territory = await repo.update(id, {\n      ...updates,\n      metadata: {\n        ...existing.metadata,\n        updatedAt: new Date(),\n        version: existing.metadata.version + 1\n      }\n    });\n\n    res.status(200).json(territory);\n  } catch (error) {\n    console.error('Error updating territory:', error);\n    res.status(500).json({ error: 'Failed to update territory' });\n  }\n}\n\nasync function handleDeleteTerritory(\n  req: NextApiRequest,\n  res: NextApiResponse,\n  repo: TerritoryRepository,\n  id: string\n) {\n  try {\n    const territory = await repo.findById(id);\n    if (!territory) {\n      return res.status(404).json({ error: 'Territory not found' });\n    }\n\n    // Check if territory is assigned\n    if (territory.assignedTo) {\n      return res.status(400).json({ \n        error: 'Cannot delete assigned territory. Unassign first.' \n      });\n    }\n\n    await repo.delete(id);\n    res.status(204).end();\n  } catch (error) {\n    console.error('Error deleting territory:', error);\n    res.status(500).json({ error: 'Failed to delete territory' });\n  }\n}\n\nexport default withAuth(handler);\n```\n\n```typescript\n// pages/api/territories/[id]/assign.ts\nimport { NextApiRequest, NextApiResponse } from 'next';\nimport { AssignTerritoryRequest } from '@/types/territory';\nimport { withAuth } from '@/middleware/auth';\nimport { TerritoryRepository } from '@/lib/repositories/territory-repository';\nimport { AssignmentRepository } from '@/lib/repositories/assignment-repository';\n\nasync function handler(req: NextApiRequest, res: NextApiResponse) {\n  const { id } = req.query;\n  const territoryRepo = new TerritoryRepository();\n  const assignmentRepo = new AssignmentRepository();\n\n  if (typeof id !== 'string') {\n    return res.status(400).json({ error: 'Invalid territory ID' });\n  }\n\n  switch (req.method) {\n    case 'POST':\n      return handleAssignTerritory(req, res, territoryRepo, assignmentRepo, id);\n    default:\n      return res.status(405).json({ error: 'Method not allowed' });\n  }\n}\n\nasync function handleAssignTerritory(\n  req: NextApiRequest,\n  res: NextApiResponse,\n  territoryRepo: TerritoryRepository,\n  assignmentRepo: AssignmentRepository,\n  territoryId: string\n) {\n  try {\n    const assignmentData: AssignTerritoryRequest = req.body;\n    const assignedBy = req.user?.id;\n\n    // Validate territory exists\n    const territory = await territoryRepo.findById(territoryId);\n    if (!territory) {\n      return res.status(404).json({ error: 'Territory not found' });\n    }\n\n    // Check if already assigned\n    if (territory.assignedTo) {\n      return res.status(400).json({ \n        error: 'Territory is already assigned',\n        currentAssignee: territory.assignedTo \n      });\n    }\n\n    // Create assignment record\n    const assignment = await assignmentRepo.create({\n      territoryId,\n      assignedTo: assignmentData.assignedTo,\n      assignedBy,\n      assignedAt: new Date(),\n      expectedCompletion: assignmentData.expectedCompletion,\n      status: 'assigned',\n      notes: assignmentData.notes\n    });\n\n    // Update territory\n    await territoryRepo.update(territoryId, {\n      assignedTo: assignmentData.assignedTo,\n      status: 'active'\n    });\n\n    res.status(201).json(assignment);\n  } catch (error) {\n    console.error('Error assigning territory:', error);\n    res.status(500).json({ error: 'Failed to assign territory' });\n  }\n}\n\nexport default withAuth(handler);\n```\n\n```typescript\n// pages/api/territories/[id]/unassign.ts\nimport { NextApiRequest, NextApiResponse } from 'next';\nimport { withAuth } from '@/middleware/auth';\nimport { TerritoryRepository } from '@/lib/repositories/territory-repository';\nimport { AssignmentRepository } from '@/lib/repositories/assignment-repository';\n\nasync function handler(req: NextApiRequest, res: NextApiResponse) {\n  if (req.method !== 'POST') {\n    return res.status(405).json({ error: 'Method not allowed' });\n  }\n\n  const { id } = req.query;\n  const territoryRepo = new TerritoryRepository();\n  const assignmentRepo = new AssignmentRepository();\n\n  if (typeof id !== 'string') {\n    return res.status(400).json({ error: 'Invalid territory ID' });\n  }\n\n  try {\n    const territory = await territoryRepo.findById(id);\n    if (!territory) {\n      return res.status(404).json({ error: 'Territory not found' });\n    }\n\n    if (!territory.assignedTo) {\n      return res.status(400).json({ error: 'Territory is not assigned' });\n    }\n\n    // Mark current assignment as reassigned\n    await assignmentRepo.updateByTerritoryId(id, { status: 'reassigned' });\n\n    // Update territory\n    await territoryRepo.update(id, {\n      assignedTo: undefined,\n      status: 'active'\n    });\n\n    res.status(200).json({ message: 'Territory unassigned successfully' });\n  } catch (error) {\n    console.error('Error unassigning territory:', error);\n    res.status(500).json({ error: 'Failed to unassign territory' });\n  }\n}\n\nexport default withAuth(handler);\n```\n\n```typescript\n// pages/api/territories/statistics.ts\nimport { NextApiRequest, NextApiResponse } from 'next';\nimport { withAuth } from '@/middleware/auth';\nimport { TerritoryRepository } from '@/lib/repositories/territory-repository';\n\nasync function handler(req: NextApiRequest, res: NextApiResponse) {\n  if (req.method !== 'GET') {\n    return res.status(405).json({ error: 'Method not allowed' });\n  }\n\n  try {\n    const territoryRepo = new TerritoryRepository();\n    const statistics = await territoryRepo.getStatistics();\n    \n    res.status(200).json(statistics);\n  } catch (error) {\n    console.error('Error fetching statistics:', error);\n    res.status(500).json({ error: 'Failed to fetch statistics' });\n  }\n}\n\nexport default withAuth(handler);\n```\n\n```typescript\n// hooks/use-territories.ts\nimport { useState, useEffect } from 'react';\nimport { Territory, TerritoryQuery, CreateTerritoryRequest, UpdateTerritoryRequest } from '@/types/territory';\nimport { TerritoryService } from '@/lib/territory-service';\n\nexport function useTerritories(query: TerritoryQuery = {}) {\n  const [territories, setTerritories] = useState<Territory[]>([]);\n  const [loading, setLoading] = useState(true);\n  const [error, setError] = useState<string | null>(null);\n  const [pagination, setPagination] = useState({\n    total: 0,\n    page: 1,\n    totalPages: 1\n  });\n\n  const territoryService = new TerritoryService('/api');\n\n  useEffect(() => {\n    loadTerritories();\n  }, [JSON.stringify(query)]);\n\n  const loadTerritories = async () => {\n    try {\n      setLoading(true);\n      const result = await territoryService.getTerritories(query);\n      setTerritories(result.territories);\n      setPagination({\n        total: result.total,\n        page: result.page,\n        totalPages: result.totalPages\n      });\n      setError(null);\n    } catch (err) {\n      setError(err.message);\n    } finally {\n      setLoading(false);\n    }\n  };\n\n  const createTerritory = async (territoryData: CreateTerritoryRequest) => {\n    try {\n      const newTerritory = await territoryService.createTerritory(territoryData);\n      setTerritories(prev => [newTerritory, ...prev]);\n      return newTerritory;\n    } catch (err) {\n      setError(err.message);\n      throw err;\n    }\n  };\n\n  const updateTerritory = async (id: string, updates: UpdateTerritoryRequest) => {\n    try {\n      const updated = await territoryService.updateTerritory(id, updates);\n      setTerritories(prev => prev.map(t => t.id === id ? updated : t));\n      return updated;\n    } catch (err) {\n      setError(err.message);\n      throw err;\n    }\n  };\n\n  const deleteTerritory = async (id: string) => {\n    try {\n      await territoryService.deleteTerritory(id);\n      setTerritories(prev => prev.filter(t => t.id !== id));\n    } catch (err) {\n      setError(err.message);\n      throw err;\n    }\n  };\n\n  const assignTerritory = async (territoryId: string, assignmentData: any) => {\n    try {\n      const assignment = await territoryService.assignTerritory(territoryId, assignmentData);\n      await loadTerritories(); // Refresh to get updated assignment info\n      return assignment;\n    } catch (err) {\n      setError(err.message);\n      throw err;\n    }\n  };\n\n  const unassignTerritory = async (territoryId: string) => {\n    try {\n      await territoryService.unassignTerritory(territoryId);\n      await loadTerritories(); // Refresh to get updated assignment info\n    } catch (err) {\n      setError(err.message);\n      throw err;\n    }\n  };\n\n  return {\n    territories,\n    loading,\n    error,\n    pagination,\n    createTerritory,\n    updateTerritory,\n    deleteTerritory,\n    assignTerritory,\n    unassignTerritory,\n    refresh: loadTerritories\n  };\n}\n```\n\nThis comprehensive Territories API provides:\n\n**Key Features:**\n- Complete CRUD operations for territories\n- Territory assignment/unassignment functionality\n- Geospatial validation and overlap detection\n- Pagination and filtering\n- Statistics and reporting\n- User territory management\n\n**API Endpoints:**\n- `GET/POST /api/territories` - List/Create territories\n- `GET/PUT/DELETE /api/territories/[id]` - Individual territory operations\n- `POST /api/territories/[id]/assign` - Assign territory\n- `POST /api/territories/[id]/unassign` - Unassign territory\n- `GET /api/territories/statistics` - Territory statistics\n\n**Advanced Features:**\n- GeoJSON polygon validation\n- Automatic area calculation\n- Overlap detection\n- Assignment history tracking\n- Territory search and filtering\n- Geospatial queries within bounds\n\nThe API handles all territory lifecycle management with proper validation, error handling, and geographic processing capabilities."
}